Finding bad message that crash S3 connector

Kafka Connect
1

Hey,

I have 2 connectors:

  1. Pull data from Postgres to Kafka
  2. Save data from Kafka to S3

After the connectors are running for a while I get the error

java.lang.NullPointerException: Array contains a null element at 0

how can I find the message that raises this error?
In addition, I added

"errors.tolerance": "all",
"errors.deadletterqueue.topic.name":"dlq_s3_sink"

to the connector configuration, but it still crashs and the “bad” message is not been sent to the DLQ.
What can I change to find the message and send it to the DLQ?

Thanks

2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.