接口的使用
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)