K
- V
- public static class ConsumerContainer.DynamicPool<K,V> extends Object implements AutoCloseable
ConsumerContainer
s (typically configured with the same group.id)
sized dynamically by setConsumerThreads(int)
Constructor and Description |
---|
DynamicPool(Properties consumerProperties,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer,
String topic,
int initialConsumerThreads,
Oneof2<Consumer<? super org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>,Consumer<? super org.apache.kafka.clients.consumer.ConsumerRecords<K,V>>> recordOrRecordsHandler,
BiConsumer<? super org.apache.kafka.clients.consumer.Consumer<?,?>,? super RuntimeException> consumerExceptionHandler) |
Modifier and Type | Method and Description |
---|---|
void |
close()
AutoCloseable
|
int |
getConsumerThreads() |
void |
setConsumerThreads(int consumerThreads)
Resize the consumer pool as requested.
|
public DynamicPool(Properties consumerProperties, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer, String topic, int initialConsumerThreads, Oneof2<Consumer<? super org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>,Consumer<? super org.apache.kafka.clients.consumer.ConsumerRecords<K,V>>> recordOrRecordsHandler, BiConsumer<? super org.apache.kafka.clients.consumer.Consumer<?,?>,? super RuntimeException> consumerExceptionHandler)
public int getConsumerThreads()
public void setConsumerThreads(int consumerThreads)
consumerThreads
- number of consumer threads to set this pool to dynamicallypublic void close()
close
in interface AutoCloseable
Copyright © 2020 Red Hat. All rights reserved.