Uses of Interface
cn.leancloud.kafka.consumer.MessageHandler

Uses of MessageHandler in cn.leancloud.kafka.consumer

Classes in cn.leancloud.kafka.consumer that implement MessageHandler

Modifier and Type	Class and Description
class	RetriableMessageHandler<K,V>
class	SafetyNetMessageHandler<K,V>

Methods in cn.leancloud.kafka.consumer with parameters of type MessageHandler

Modifier and Type	Method and Description
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.

Constructors in cn.leancloud.kafka.consumer with parameters of type MessageHandler

Constructor and Description
RetriableMessageHandler(MessageHandler<K,V> innerHandler, int maxRetryTimes)
SafetyNetMessageHandler(MessageHandler<K,V> innerHandler)
SafetyNetMessageHandler(MessageHandler<K,V> innerHandler, BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,Throwable> errorConsumer)