THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Config Option | Description | Default Value | Domain |
|---|---|---|---|
| errors.dlq.enable | Write the error context into a Kafka topic | false | Boolean |
| errors.dlq.topic.name | The name of the topic where these messages are written to | "" | A valid Kafka topic name |
| errors.dlq.topic.partitions | Number of partitions for this topic | 5 | [1, 2 .. Integer.MAX_INT] |
| errors.dlq.topic.replication.factor | The replication factor for this topic | 3 | [1, 2 .. IntegerShort.MAX_INTSHORT] |
| errors.dlq.include.configs | Include the (worker, connector) configs in the log. | false | Boolean |
| errors.dlq.include.messages | Include the Connect Record which failed to process in the log. | false | Boolean |
| errors.dlq.producer.* | Config for the KafkaProduce to produce to this topic (for example: errors.dlq.producer.bootstrap.servers will set the bootstrap servers of the Kafka cluster). | ||
| errors.dlq.converter | Converter class used to convert the error context between Kafka Connect format and the serialized form that is written to Kafka. | org.apache.kafka. connect.json.JsonConverter | Any class which implements org.apache.kafka.connect.storage.Converter |
...