Uses of Class
io.helidon.messaging.connectors.kafka.KafkaSubscriber.Builder
-
Uses of KafkaSubscriber.Builder in io.helidon.messaging.connectors.kafka
Modifier and TypeMethodDescriptionKafkaSubscriber.Builder.backpressure
(long backpressure) Specifies the number of messages that are requested after processing them.static <K,
V> KafkaSubscriber.Builder <K, V> KafkaSubscriber.builder()
A builder for KafkaSubscriber.Load this builder from a configuration.KafkaSubscriber.Builder.producerSupplier
(Supplier<org.apache.kafka.clients.producer.Producer<K, V>> producerSupplier) Defines how to instantiate the KafkaSubscriber.The list of topics the messages should be sent to.