Uses of Class
cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

Uses of LcKafkaConsumerBuilder in cn.leancloud.kafka.consumer

Methods in cn.leancloud.kafka.consumer that return LcKafkaConsumerBuilder

Modifier and Type	Method and Description
LcKafkaConsumerBuilder<K,V>	LcKafkaConsumerBuilder.gracefulShutdownMs(Duration duration)
LcKafkaConsumerBuilder<K,V>	LcKafkaConsumerBuilder.gracefulShutdownMs(long gracefulShutdownMs)
LcKafkaConsumerBuilder<K,V>	LcKafkaConsumerBuilder.maxPendingAsyncCommits(int maxPendingAsyncCommits) When using async consumer to commit offset asynchronously, this argument can force consumer to do a synchronous commit after there's already maxPendingAsyncCommits async commits on the fly without response from broker.
LcKafkaConsumerBuilder<K,V>	LcKafkaConsumerBuilder.messageHandler(MessageHandler<K,V> messageHandler) Change the MessageHandler to handle the consumed msg from kafka.
static <K,V> LcKafkaConsumerBuilder<K,V>	LcKafkaConsumerBuilder.newBuilder(Map<String,Object> kafkaConfigs, MessageHandler<K,V> messageHandler) Create a LcKafkaConsumerBuilder used to build LcKafkaConsumer.
static <K,V> LcKafkaConsumerBuilder<K,V>	LcKafkaConsumerBuilder.newBuilder(Map<String,Object> kafkaConfigs, MessageHandler<K,V> messageHandler, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer) Create a LcKafkaConsumerBuilder used to build LcKafkaConsumer.
LcKafkaConsumerBuilder<K,V>	LcKafkaConsumerBuilder.pollTimeout(Duration pollTimeout) The pollTimeout is the maximum time spent waiting in polling data from kafka broker if data is not available in the buffer.
LcKafkaConsumerBuilder<K,V>	LcKafkaConsumerBuilder.pollTimeoutMs(long pollTimeoutMs) The pollTimeout is the maximum time spent waiting in polling data from kafka broker if data is not available in the buffer.
LcKafkaConsumerBuilder<K,V>	LcKafkaConsumerBuilder.workerPool(ExecutorService workerPool, boolean shutdownOnStop) The thread pool used by consumer to handle the consumed messages from kafka.