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.