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

Classes in com.github.ddth.queue.impl with type parameters of type KafkaQueue

Modifier and Type	Class and Description
class	KafkaQueueFactory<T extends KafkaQueue> Factory to create KafkaQueue instances.

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 implementations.

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

Modifier and Type	Method and Description
KafkaQueue	KafkaQueue.init() Init method.
KafkaQueue	KafkaQueue.setConsumerGroupId(String consumerGroupId)
KafkaQueue	KafkaQueue.setKafkaBootstrapServers(String kafkaBootstrapServers) Sets Kafka bootstrap server list (format host1:9092,host2:port2,host3:port3).
KafkaQueue	KafkaQueue.setKafkaClient(com.github.ddth.kafka.KafkaClient kafkaClient) An external KafkaClient can be used.
KafkaQueue	KafkaQueue.setKafkaConsumerProperties(Properties kafkaConsumerConfigs) Sets Kafka consumer's custom configuration properties.
KafkaQueue	KafkaQueue.setKafkaProducerProperties(Properties kafkaProducerConfigs) Sets Kafka producer's custom configuration properties.
KafkaQueue	KafkaQueue.setProducerType(com.github.ddth.kafka.KafkaClient.ProducerType producerType)
KafkaQueue	KafkaQueue.setTopicName(String topicName)

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.