Uses of Class
com.github.ddth.queue.impl.KafkaQueue

Packages that use KafkaQueue

Package	Description
com.github.ddth.queue.impl
com.github.ddth.queue.impl.universal

Uses of KafkaQueue in com.github.ddth.queue.impl

Subclasses of KafkaQueue in com.github.ddth.queue.impl

Modifier and Type	Class and Description
class	BaseUniversalKafkaQueue<T extends BaseUniversalQueueMessage> Base class for universal Kafka queue implementation.

Methods in com.github.ddth.queue.impl that return KafkaQueue

Modifier and Type	Method and Description
KafkaQueue	KafkaQueue.init() Init method.
KafkaQueue	KafkaQueue.setBufferSize(int bufferSize)
KafkaQueue	KafkaQueue.setConsumerGroupId(String consumerGroupId)
KafkaQueue	KafkaQueue.setKafkaClient(com.github.ddth.kafka.KafkaClient kafkaClient) An external KafkaClient can be used.
KafkaQueue	KafkaQueue.setLeaderAutoRebalance(boolean leaderAutoRebalance)
KafkaQueue	KafkaQueue.setOffsetCommitPeriodMs(long offsetCommitPeriodMs)
KafkaQueue	KafkaQueue.setProducerType(com.github.ddth.kafka.KafkaClient.ProducerType producerType)
KafkaQueue	KafkaQueue.setTopicName(String topicName)
KafkaQueue	KafkaQueue.setZkConnString(String zkConnString) Sets Zookeeper connection string (format host1:port1,host2:port2,host3:port3/path).

Uses of KafkaQueue in com.github.ddth.queue.impl.universal

Subclasses of KafkaQueue in com.github.ddth.queue.impl.universal

Modifier and Type	Class and Description
class	UniversalKafkaQueue (Experimental) Universal Kafka implementation of IQueue.