public class KafkaMessageConsumerManager extends AbstractMessageConsumerManager implements org.springframework.beans.factory.InitializingBean
SINK_INITIAL_SLEEP_TIME, waitForStartup
LOG_PREFIX
Constructor and Description |
---|
KafkaMessageConsumerManager() |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
protected void |
startConsumingForModule(SinkModule<?,Message> module) |
protected void |
stopConsumingForModule(SinkModule<?,Message> module) |
dispatch, getNumConsumerThreads, registerConsumer, unregisterAllConsumers, unregisterConsumer
protected void startConsumingForModule(SinkModule<?,Message> module) throws Exception
startConsumingForModule
in class AbstractMessageConsumerManager
Exception
protected void stopConsumingForModule(SinkModule<?,Message> module) throws Exception
stopConsumingForModule
in class AbstractMessageConsumerManager
Exception
Copyright © 2017. All rights reserved.