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.
|