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

类 KafkaConsumeGroup

java.lang.Object

xin.manong.weapon.base.kafka.KafkaConsumeGroup

public class KafkaConsumeGroup
extends Object

kafka消费组

作者:

frankcl

构造器概要

构造器

构造器	说明
KafkaConsumeGroup(KafkaConsumeConfig config)
KafkaConsumeGroup(KafkaConsumeConfig config, KafkaRecordProcessor processor)

方法概要

修饰符和类型	方法	说明
void	setProcessor(KafkaRecordProcessor processor)	设置数据处理器
boolean	start()	启动kafka消费组
void	stop()	停止kafka消费组

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

KafkaConsumeGroup

public KafkaConsumeGroup(KafkaConsumeConfig config)

KafkaConsumeGroup

public KafkaConsumeGroup(KafkaConsumeConfig config,
                         KafkaRecordProcessor processor)

方法详细资料

start

public boolean start()

启动kafka消费组

返回:

启动成功返回true，否则返回false

stop

public void stop()

停止kafka消费组

setProcessor

public void setProcessor(KafkaRecordProcessor processor)

设置数据处理器

参数:

processor - 数据处理器