io.helidon.messaging.connectors.kafka.KafkaConfigBuilder

Description

Build Kafka specific config

Configuration options

Key	Type	Description
value-deserializer	Class	Deserializer class for value that implements the org.apache.kafka.common.serialization.Deserializer interface
group-id	String	A unique string that identifies the consumer group this consumer belongs to
auto-offset-reset	AutoOffsetReset	What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g
topic-pattern	Pattern	Pattern for topic names to consume from
acks	String	The number of acknowledgments the producer requires the leader to have received before considering a request complete
bootstrap-servers	String	A list of host/port pairs to use for establishing the initial connection to the Kafka cluster
key-serializer	Class	Serializer class for key that implements the org.apache.kafka.common.serialization.Serializer interface
enable-auto-commit	Boolean	If true the consumer's offset will be periodically committed in the background
batch-size	Integer	The producer will attempt to batch records together into fewer requests whenever multiple records are being sent to the same partition
dlq-topic	List<String>	Names of the "dead letter queue" topics to be used in case message is nacked
retries	Integer	Setting a value greater than zero will cause the client to resend any record whose send fails with a potentially transient error
buffer-memory	Long	The total bytes of memory the producer can use to buffer records waiting to be sent to the server
poll-timeout	Long	The maximum time to block polling loop in milliseconds
compression-type	String	The compression type for all data generated by the producer
topic	List<String>	Names of the topics to consume from
value-serializer	Class	Serializer class for value that implements the org.apache.kafka.common.serialization.Serializer interface
period-executions	Long	Period between successive executions of polling loop
key-deserializer	Class	Deserializer class for key that implements the org.apache.kafka.common.serialization.Deserializer interface

---

See the manifest for all available types.