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

Packages that use KafkaQueue

Package	Description
com.github.ddth.queue.impl

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	UniversalKafkaQueue Universal Kafka implementation of IQueue.

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

Modifier and Type	Method and Description
KafkaQueue	KafkaQueue.init() Init method.
KafkaQueue	KafkaQueue.setKafkaClient(com.github.ddth.kafka.KafkaClient kafkaClient)
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).