Configuration Reference

Version:5.5.0

Micronaut Kafka Config Properties

Table 1. 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 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 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 4. Configuration Properties for KafkaHealthConfigurationProperties
Property	Type	Description
`kafka.health-timeout`	java.time.Duration	The health check timeout.
`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

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.