Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Cluster level configuration

...

Public Interfaces

Configuration

...

Cluster configuration

These are dynamic configurations defined at the cluster level.

ConfigurationDescriptionValues
errors.deadletterqueue.auto.create.topics.enable Whether to create DLQ topics automatically. Note that automatic creation of the DLQ topics is independent of the auto.create.topics.enable  configuration.Type: boolean, default: false 
errors.deadletterqueue.topic.name.prefix The prefix of permitted dead-letter queue topic names. If this is set to "", there is no restriction on the names used for dead-letter queue topics.Type: string, default: "dlq." 

For example, the following command would enable auto-creation of DLQ topics for the cluster.

Code Block
$ bin/kafka-config.sh --bootstrap-server localhost:9092 --alter --entity-type brokers --entity-default --add-config errors.deadletterqueue.auto.create.topics.enable=true

If KIP-1210: Disallow Configurations at the Broker Level is adopted, these configurations will be added to the list of those which are not permitted at the individual broker level.

Group configuration

Note that these configuration property names do not begin with share  even though they are initially only relevant to the behavior of share groups. This is because the concept is likely to be applicable to other group types in the future.

...

Metric NameTypeGroupTagsDescriptionJMX Bean
DeadLetterQueueRecordCount MeterShareGroupMetricsgroup: <group_id> The number of records written to the dead-letter queue topic.

kafka.server:type=ShareGroupMetrics,name=DeadLetterQueueRecordCount

kafka.server:type=ShareGroupMetrics,name=DeadLetterQueueRecordCount,group={group_id} 

DeadLetterQueueProduceRequestsPerSecDeadLetterQueueTotalProduceRequestsPerSec MeterShareGroupMetricsgroup: <group_id> The rate of produce requests writing records to the dead-letter queue topic.

kafka.server:type=ShareGroupMetrics,name=DeadLetterQueueProduceRequestsPerSecDeadLetterQueueTotalProduceRequestsPerSec

kafka.server:type=ShareGroupMetrics,name=DeadLetterQueueProduceRequestsPerSecDeadLetterQueueTotalProduceRequestsPerSec,group={group_id} 

DeadLetterQueueFailedProduceRequestsPerSec MeterShareGroupMetricsgroup: <group_id> The rate of failed produce requests writing records to the dead-letter queue topic.

kafka.server:type=ShareGroupMetrics,name=DeadLetterQueueFailedProduceRequestsPerSec

kafka.server:type=ShareGroupMetrics,name=DeadLetterQueueFailedProduceRequestsPerSec,group={group_id}

Compatibility, Deprecation, and Migration Plan

...