Configuration Reference

Version:1.0.4

Kafka Config Properties

🔗
Table 1. Configuration Properties for KafkaProducerConfiguration
Property Type Description

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.

🔗
Table 2. Configuration Properties for KafkaConsumerConfiguration
Property Type Description

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 KafkaDefaultConfiguration
Property Type Description

kafka.health-timeout

java.time.Duration

The health check timeout. Default value (1 seconds).

🔗
Table 4. Configuration Properties for KafkaEmbeddedConfiguration
Property Type Description

kafka.embedded.enabled

boolean

Sets whether the embedded Kafka server is enabled. Default value (false).

kafka.embedded.topics

java.util.List

The topics that should be created by the embedded instance.

kafka.embedded.properties

java.util.Properties

Sets the broker properties.