| 程序包 | 说明 |
|---|---|
| com.github.panhongan.util.kafka |
| 限定符和类型 | 类和说明 |
|---|---|
class |
MessageConsoleWriter |
class |
MessageKafkaWriter |
class |
MessageLocalWriter |
| 构造器和说明 |
|---|
HighLevelConsumer(kafka.consumer.KafkaStream<byte[],byte[]> stream,
String topic,
int partition_id,
AbstractMessageProcessor msg_processor) |
| 构造器和说明 |
|---|
HighLevelConsumerGroup(String zk_list,
String group_id,
String topic,
int partition,
boolean restart_offset_largest,
List<AbstractMessageProcessor> msg_processors) |
Copyright © 2016. All rights reserved.