THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Config Option | Description | Default Value | Domain | ||||
---|---|---|---|---|---|---|---|
errors.dlqdeadletterqueue.enable | Write the error context into a Kafka topic | false | Boolean | ||||
errors.dlqdeadletterqueue.topic.name | The name of the topic where these messages are written to | "" | A valid Kafka topic name | ||||
errors.dlqdeadletterqueue.topic.partitions | Number of partitions for this topic | 5 | [1, 2 .. Integer.MAX_INT] | ||||
errors.dlqdeadletterqueue.topic.replication.factor | The replication factor for this topic | 3 | [1, 2 .. Short.MAX_SHORT] | ||||
errors.dlqdeadletterqueue.include.configs | Include the (worker, connector) configs in the log. | false | Boolean | ||||
errors.dlqdeadletterqueue.include.messages | Include the Connect Record which failed to process in the log. | false | Boolean | ||||
errors.dlqdeadletterqueue.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 |
Metrics
The following new metrics will monitor the number of failures, and the behavior of the response handler. Specifically, the following set of counters:
...