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>>> recordOrRecordsConsumer,
long idlePingTimeout,
Consumer<? super org.apache.kafka.common.TopicPartition> idlePingConsumer) |
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>>> recordOrRecordsConsumer) |
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>>> recordOrRecordsConsumer) |