| Package | Description |
|---|---|
| com.github.ddth.queue.impl | |
| com.github.ddth.queue.impl.universal |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseUniversalKafkaQueue<T extends BaseUniversalQueueMessage>
Base class for universal Kafka queue implementation.
|
| 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). |
| Modifier and Type | Class and Description |
|---|---|
class |
UniversalKafkaQueue
(Experimental) Universal Kafka implementation of
IQueue. |
Copyright © 2015 DDTH. All Rights Reserved.