I have 2 connectors:
- Pull data from Postgres to Kafka
- 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?