Small config issue: Kafka Sink Connector Configuration Debugging

I'm using Kafka 2.6.0 with a sink connector to Postgres on Confluent Cloud. The issue I'm facing is due to extensive modifications to the default configurations for the sink connector.

Key Points:

- The primary issue I'm encountering is related to the configuration of the sink connector.

- The connector is not functioning correctly, and data is not arriving in Postgres as expected.

- I have made significant modifications to the default configurations for the sink connector.

I need an expert who is proficient in Kafka, Confluent Cloud, and sink connector configuration to help debug and rectify the issue. You should be able to:

- Analyze and troubleshoot the sink connector configuration to identify the root cause of the problem.

- Make necessary amendments to the configurations that I have altered to ensure they are in line with best practices and compatible with my setup.

- Ensure that data is properly flowing from Kafka to Postgres through the sink connector.

All the messages are getting processed and connector is pushing them to dead letter queue. it should be pretty simple but I'm missing something small.

Exception is as follows:

{

"key": "[login to view URL]",

"value": "Converting byte[] to Kafka Connect data failed due to serialization error of topic sales: "

},

If you have relevant experience in debugging Kafka sink connector issues and working with Confluent Cloud, your expertise would be invaluable in resolving this problem.

Apache Kafka Java

Rif. progetto: #38049956

Info sul progetto