com.github.panhongan.util.kafka

类 HighLevelConsumerGroup

java.lang.Object

com.github.panhongan.util.kafka.HighLevelConsumerGroup

所有已实现的接口:

Lifecycleable

public class HighLevelConsumerGroup
extends Object
implements Lifecycleable

构造器概要

构造器

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

方法概要

方法

限定符和类型	方法和说明
boolean	init()
void	uninit()

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

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

构造器详细资料

HighLevelConsumerGroup

public HighLevelConsumerGroup(String zk_list,
                      String group_id,
                      String topic,
                      int partition,
                      boolean restart_offset_largest,
                      List<AbstractKafkaMessageProcessor> msg_processors)

方法详细资料

init

public boolean init()

指定者:

init 在接口中 Lifecycleable

uninit

public void uninit()

指定者:

uninit 在接口中 Lifecycleable