Uses of Class
io.helidon.messaging.connectors.kafka.KafkaConfigBuilder

Packages that use KafkaConfigBuilder

Package	Description
io.helidon.messaging.connectors.kafka	Microprofile messaging Kafka connector.

Uses of KafkaConfigBuilder in io.helidon.messaging.connectors.kafka

Methods in io.helidon.messaging.connectors.kafka that return KafkaConfigBuilder

Modifier and Type	Method	Description
KafkaConfigBuilder	KafkaConfigBuilder.acks(String acks)	The number of acknowledgments the producer requires the leader to have received before considering a request complete.
KafkaConfigBuilder	KafkaConfigBuilder.autoOffsetReset(KafkaConfigBuilder.AutoOffsetReset 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.
KafkaConfigBuilder	KafkaConfigBuilder.batchSize(int batchSize)	The producer will attempt to batch records together into fewer requests whenever multiple records are being sent to the same partition.
KafkaConfigBuilder	KafkaConfigBuilder.bootstrapServers(String servers)	A list of host/port pairs to use for establishing the initial connection to the Kafka cluster.
KafkaConfigBuilder	KafkaConfigBuilder.bufferMemory(long bufferMemory)	The total bytes of memory the producer can use to buffer records waiting to be sent to the server.
KafkaConfigBuilder	KafkaConfigBuilder.compressionType(String compressionType)	The compression type for all data generated by the producer.
static KafkaConfigBuilder	KafkaConnector.configBuilder()	Custom config builder for Kafka connector.
KafkaConfigBuilder	KafkaConfigBuilder.dlqTopic(String... topics)	Names of the "dead letter queue" topics to be used in case message is nacked.
KafkaConfigBuilder	KafkaConfigBuilder.enableAutoCommit(boolean enableAutoCommit)	If true the consumer's offset will be periodically committed in the background.
KafkaConfigBuilder	KafkaConfigBuilder.groupId(String groupId)	A unique string that identifies the consumer group this consumer belongs to.
KafkaConfigBuilder	KafkaConfigBuilder.keyDeserializer(Class<? extends org.apache.kafka.common.serialization.Deserializer<?>> keyDeserializer)	Deserializer class for key that implements the Deserializer interface.
KafkaConfigBuilder	KafkaConfigBuilder.keySerializer(Class<? extends org.apache.kafka.common.serialization.Serializer<?>> keySerializer)	Serializer class for key that implements the Serializer interface.
KafkaConfigBuilder	KafkaConfigBuilder.periodExecutions(long periodExecutions)	Period between successive executions of polling loop.
KafkaConfigBuilder	KafkaConfigBuilder.pollTimeout(long pollTimeout)	The maximum time to block polling loop in milliseconds.
KafkaConfigBuilder	KafkaConfigBuilder.property(String key, String value)	Add custom property.
KafkaConfigBuilder	KafkaConfigBuilder.retries(int retries)	Setting a value greater than zero will cause the client to resend any record whose send fails with a potentially transient error.
KafkaConfigBuilder	KafkaConfigBuilder.topic(String... topics)	Names of the topics to consume from.
KafkaConfigBuilder	KafkaConfigBuilder.topicPattern(String topicPattern)	Regex pattern for topic names to consume from.
KafkaConfigBuilder	KafkaConfigBuilder.topicPattern(Pattern topicPattern)	Pattern for topic names to consume from.
KafkaConfigBuilder	KafkaConfigBuilder.valueDeserializer(Class<? extends org.apache.kafka.common.serialization.Deserializer<?>> valueDeserializer)	Deserializer class for value that implements the Deserializer interface.
KafkaConfigBuilder	KafkaConfigBuilder.valueSerializer(Class<? extends org.apache.kafka.common.serialization.Serializer<?>> valueSerializer)	Serializer class for value that implements the Serializer interface.