Uses of Class
io.helidon.messaging.connectors.kafka.KafkaPublisher.Builder

Packages that use KafkaPublisher.Builder

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

Uses of KafkaPublisher.Builder in io.helidon.messaging.connectors.kafka

Methods in io.helidon.messaging.connectors.kafka that return KafkaPublisher.Builder

Modifier and Type	Method	Description
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.ackTimeout(long ackTimeout)	This value applies only when autoCommit is set to false.
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.autoCommit(boolean autoCommit)	This flag defines the strategy of committing messages to Kafka.
static <K, V> KafkaPublisher.Builder<K,V>	KafkaPublisher.builder()	A builder for KafkaPublisher.
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.config(Config config)	Load this builder from a configuration.
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.consumerSupplier(Supplier<org.apache.kafka.clients.consumer.Consumer<K,V>> consumerSupplier)	Defines how to instantiate the KafkaConsumer.
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.limitNoAck(int limitNoAck)	This value applies only when autoCommit is set to false.
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.periodExecutions(long periodExecutions)	Specifies the period in milliseconds between successive scheduler executions.
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.pollTimeout(long pollTimeout)	Specifies maximum time in milliseconds to block polling messages from Kafka.
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.scheduler(ScheduledExecutorService scheduler)	Specify a scheduler that will read ad process messages coming from Kafka.
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.topicPattern(Pattern topicPattern)	The pattern for selecting multiple topics.
KafkaPublisher.Builder<K,V>	KafkaPublisher.Builder.topics(List<String> topics)	The list of topics to subscribe to.