KafkaSubscriber.Builder<K,V> |
KafkaSubscriber.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.
|
KafkaSubscriber.Builder<K,V> |
KafkaSubscriber.Builder.config(Config config) |
Load this builder from a configuration.
|
KafkaSubscriber.Builder<K,V> |
KafkaSubscriber.Builder.producerSupplier(Supplier<org.apache.kafka.clients.producer.Producer<K,V>> producerSupplier) |
Defines how to instantiate the KafkaSubscriber.
|
KafkaSubscriber.Builder<K,V> |
KafkaSubscriber.Builder.topics(List<String> topics) |
The list of topics the messages should be sent to.
|