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

使用AbstractKafkaMessageProcessor的程序包

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

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

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

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

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

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

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

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

com.github.panhongan.util.kafka.handler中AbstractKafkaMessageProcessor的使用

com.github.panhongan.util.kafka.handler中AbstractKafkaMessageProcessor的子类

限定符和类型	类和说明
class	KafkaMessageWorkflow