Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Config OptionDescriptionDefault ValueDomain
errors.log.enableLog the error context (the base information, configs of various stages and the record which caused the failure) along with the other application logs.falseBoolean
errors.log.include.configsInclude the (connector) whether to include the configs in the log.falseBoolean
errors.log.include.messagesInclude whether to include the Connect Record which failed to process in the log.falseBoolean

...

Config OptionDescriptionDefault ValueDomain
errors.deadletterqueue.enableWrite the error context (the base information, configs of various stages and the record which caused the failure) into a Kafka topicfalseBoolean
errors.deadletterqueue.topic.nameThe name of the topic where these messages are written to""A valid Kafka topic name
errors.deadletterqueue.topic.partitionsNumber of partitions for this topic5[1, 2 .. Integer.MAX_INT]
errors.deadletterqueue.topic.replication.factorThe replication factor for this topic3[1, 2 .. Short.MAX_SHORT]
errors.deadletterqueue.include.configsInclude the (connector) whether to include the configs in the log.falseBoolean
errors.deadletterqueue.include.messagesInclude the Connect Record which whether to include the record which failed to process in the log.falseBoolean
errors.deadletterqueue.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).  

...