接口的使用
xin.manong.weapon.base.kafka.KafkaRecordProcessor

使用KafkaRecordProcessor的程序包

程序包	说明
xin.manong.weapon.base.kafka

xin.manong.weapon.base.kafka中KafkaRecordProcessor的使用

参数类型为KafkaRecordProcessor的xin.manong.weapon.base.kafka中的方法

限定符和类型	方法和说明
void	KafkaConsumeGroup.setProcessor(KafkaRecordProcessor processor) 设置数据处理器

参数类型为KafkaRecordProcessor的xin.manong.weapon.base.kafka中的构造器

构造器和说明
KafkaConsumeGroup(KafkaConsumeConfig config, KafkaRecordProcessor processor)
KafkaConsumer(String name, KafkaConsumeConfig config, KafkaRecordProcessor processor)