Configuration Reference

Version:5.7.1-SNAPSHOT

Micronaut Kafka Config Properties

Table 1. Configuration Properties for KafkaProducerConfiguration
Property	Type	Description
`kafka.producers.*.key-serializer`	org.apache.kafka.common.serialization.Serializer
`kafka.producers.*.value-serializer`	org.apache.kafka.common.serialization.Serializer
`kafka.producers.*.executor`	java.lang.String

Table 2. Configuration Properties for DefaultKafkaListenerExceptionHandlerConfigurationProperties
Property	Type	Description
`kafka.default-listener-exception-handler.skip-record-on-deserialization-failure`	boolean	Whether to skip record on deserialization failure. Default value true
`kafka.default-listener-exception-handler.commit-record-on-deserialization-failure`	boolean	Whether to commit record on deserialization failure. Default value false

Table 3. Configuration Properties for KafkaConsumerConfiguration
Property	Type	Description
`kafka.consumers.*.key-deserializer`	org.apache.kafka.common.serialization.Deserializer
`kafka.consumers.*.value-deserializer`	org.apache.kafka.common.serialization.Deserializer

Table 4. Configuration Properties for KafkaHealthConfigurationProperties
Property	Type	Description
`kafka.health.enabled`	boolean	Whether the Kafka health check is enabled. Default value true.
`kafka.health.restricted`	boolean	By default, the health check requires cluster-wide permissions in order to get information about the nodes in the Kafka cluster. If your application doesn’t have admin privileges (for example, this might happen in multi-tenant scenarios), you can switch to a "restricted" version of the health check which only validates basic connectivity but doesn’t require any additional permissions.. Default value false
`kafka.health-timeout`	java.time.Duration	The health check timeout.

Micronaut Kafka Streams Config Properties

Table 5. Configuration Properties for KafkaStreamsConfiguration
Property	Type	Description
`kafka.streams.*.close-timeout`	java.time.Duration	The time to wait for the stream to shut down. Default value is 3s.
`kafka.streams.*.name`	java.lang.String	The logical name of the stream.