类 com.github.panhongan.util.kafka.AbstractMessageProcessor
的使用

使用AbstractMessageProcessor的程序包

程序包	说明
com.github.panhongan.util.kafka

com.github.panhongan.util.kafka中AbstractMessageProcessor的使用

com.github.panhongan.util.kafka中AbstractMessageProcessor的子类

限定符和类型	类和说明
class	MessageConsoleWriter
class	MessageKafkaWriter
class	MessageLocalWriter

参数类型为AbstractMessageProcessor的com.github.panhongan.util.kafka中的构造器

构造器和说明
HighLevelConsumer(kafka.consumer.KafkaStream<byte[],byte[]> stream, String topic, int partition_id, AbstractMessageProcessor msg_processor)

类型变量类型为AbstractMessageProcessor的com.github.panhongan.util.kafka中的构造器参数

构造器和说明
HighLevelConsumerGroup(String zk_list, String group_id, String topic, int partition, boolean restart_offset_largest, List<AbstractMessageProcessor> msg_processors)