Configuration Reference

Version:6.0.0-SNAPSHOT

Micronaut Kafka Config Properties

Table 1. Configuration Properties for KafkaDefaultConfiguration
Property	Type	Description	Default value
`kafka.health-timeout`	java.time.Duration	The health check timeout. Default value (10 seconds).

Table 2. Configuration Properties for KafkaConsumerConfiguration
Property	Type	Description	Default value
`kafka.consumers.*.key-deserializer`	org.apache.kafka.common.serialization.Deserializer	Sets the key deserializer.
`kafka.consumers.*.value-deserializer`	org.apache.kafka.common.serialization.Deserializer	Sets the default value deserializer.

Table 3. Configuration Properties for DefaultKafkaListenerExceptionHandlerConfigurationProperties
Property	Type	Description	Default value
`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 4. Configuration Properties for KafkaHealthConfigurationProperties
Property	Type	Description	Default value
`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

Table 5. Configuration Properties for KafkaProducerConfiguration
Property	Type	Description	Default value
`kafka.producers.*.key-serializer`	org.apache.kafka.common.serialization.Serializer	Sets the key serializer.
`kafka.producers.*.value-serializer`	org.apache.kafka.common.serialization.Serializer	Sets the default value serializer.
`kafka.producers.*.executor`	java.lang.String	Sets the default executor to use to enable non-blocking producers.

Micronaut Kafka Streams Config Properties

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