A B C G H L M N P R S T W

A

addPendingRecord(ConsumerRecord<K, V>) - Method in interface cn.leancloud.kafka.consumer.CommitPolicy

B

buildAsync() - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

buildAuto() - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

Build a consumer which commit offset automatically in fixed interval.

buildPartialAsync() - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

buildPartialSync() - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

buildSync() - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

C

close() - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumer

cn.leancloud.kafka.consumer - package cn.leancloud.kafka.consumer

CommitPolicy<K,V> - Interface in cn.leancloud.kafka.consumer

completeRecord(ConsumerRecord<K, V>) - Method in interface cn.leancloud.kafka.consumer.CommitPolicy

G

gracefulShutdownMs(long) - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

gracefulShutdownMs(Duration) - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

H

handleMessage(ConsumerRecord<K, V>) - Method in interface cn.leancloud.kafka.consumer.MessageHandler

handleMessage(ConsumerRecord<K, V>) - Method in class cn.leancloud.kafka.consumer.RetriableMessageHandler

handleMessage(ConsumerRecord<K, V>) - Method in class cn.leancloud.kafka.consumer.SafetyNetMessageHandler

HandleMessageFailedException - Exception in cn.leancloud.kafka.consumer

HandleMessageFailedException() - Constructor for exception cn.leancloud.kafka.consumer.HandleMessageFailedException

HandleMessageFailedException(String) - Constructor for exception cn.leancloud.kafka.consumer.HandleMessageFailedException

HandleMessageFailedException(Throwable) - Constructor for exception cn.leancloud.kafka.consumer.HandleMessageFailedException

HandleMessageFailedException(String, Throwable) - Constructor for exception cn.leancloud.kafka.consumer.HandleMessageFailedException

L

LcKafkaConsumer<K,V> - Class in cn.leancloud.kafka.consumer

LcKafkaConsumerBuilder<K,V> - Class in cn.leancloud.kafka.consumer

M

maxPendingAsyncCommits(int) - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

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.

messageHandler(MessageHandler<K, V>) - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

Change the MessageHandler to handle the consumed msg from kafka.

MessageHandler<K,V> - Interface in cn.leancloud.kafka.consumer

N

NamedThreadFactory - Class in cn.leancloud.kafka.consumer

Internal use only, may change in the future.

NamedThreadFactory(String) - Constructor for class cn.leancloud.kafka.consumer.NamedThreadFactory

NamedThreadFactory(String, boolean) - Constructor for class cn.leancloud.kafka.consumer.NamedThreadFactory

newBuilder(Map<String, Object>, MessageHandler<K, V>) - Static method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

Create a LcKafkaConsumerBuilder used to build LcKafkaConsumer.

newBuilder(Map<String, Object>, MessageHandler<K, V>, Deserializer<K>, Deserializer<V>) - Static method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

Create a LcKafkaConsumerBuilder used to build LcKafkaConsumer.

newThread(Runnable) - Method in class cn.leancloud.kafka.consumer.NamedThreadFactory

NonNullByDefault - Annotation Type in cn.leancloud.kafka.consumer

An annotation that signifies the return values, parameters and fields are non-nullable by default leveraging the JSR-305 Nonnull annotation.

P

partialCommit() - Method in interface cn.leancloud.kafka.consumer.CommitPolicy

pollTimeout(Duration) - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

The pollTimeout is the maximum time spent waiting in polling data from kafka broker if data is not available in the buffer.

pollTimeoutMs(long) - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

The pollTimeout is the maximum time spent waiting in polling data from kafka broker if data is not available in the buffer.

R

RetriableMessageHandler<K,V> - Class in cn.leancloud.kafka.consumer

RetriableMessageHandler(MessageHandler<K, V>, int) - Constructor for class cn.leancloud.kafka.consumer.RetriableMessageHandler

S

SafetyNetMessageHandler<K,V> - Class in cn.leancloud.kafka.consumer

SafetyNetMessageHandler(MessageHandler<K, V>) - Constructor for class cn.leancloud.kafka.consumer.SafetyNetMessageHandler

SafetyNetMessageHandler(MessageHandler<K, V>, BiConsumer<ConsumerRecord<K, V>, Throwable>) - Constructor for class cn.leancloud.kafka.consumer.SafetyNetMessageHandler

subscribe(Collection<String>) - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumer

T

tryCommit(boolean) - Method in interface cn.leancloud.kafka.consumer.CommitPolicy

W

workerPool(ExecutorService, boolean) - Method in class cn.leancloud.kafka.consumer.LcKafkaConsumerBuilder

The thread pool used by consumer to handle the consumed messages from kafka.

A B C G H L M N P R S T W