ConsumerContainer(Properties consumerProperties,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer,
long consumerPollTimeout,
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,
long idlePingTimeout,
Consumer<? super org.apache.kafka.common.TopicPartition> idlePingHandler) |
ConsumerContainer(Properties consumerProperties,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer,
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) |
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) |