public class KafkaMessageConsumerManager extends AbstractMessageConsumerManager implements org.springframework.beans.factory.InitializingBean
SINK_INITIAL_SLEEP_TIME, waitForStartup
LOG_PREFIX, METRIC_DISPATCH_TIME, METRIC_MESSAGE_SIZE, METRIC_MESSAGES_RECEIVED
Constructor and Description |
---|
KafkaMessageConsumerManager() |
KafkaMessageConsumerManager(KafkaConfigProvider configProvider) |
KafkaMessageConsumerManager(KafkaConfigProvider configProvider,
Identity identity,
TracerRegistry tracerRegistry,
com.codahale.metrics.MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
Identity |
getIdentity() |
com.codahale.metrics.MetricRegistry |
getMetricRegistry() |
io.opentracing.Tracer |
getTracer() |
TracerRegistry |
getTracerRegistry() |
void |
setIdentity(Identity identity) |
void |
setMetricRegistry(com.codahale.metrics.MetricRegistry metricRegistry) |
void |
setTracerRegistry(TracerRegistry tracerRegistry) |
protected void |
startConsumingForModule(SinkModule<?,Message> module) |
protected void |
stopConsumingForModule(SinkModule<?,Message> module) |
dispatch, getNumConsumerThreads, registerConsumer, unregisterAllConsumers, unregisterConsumer
public KafkaMessageConsumerManager()
public KafkaMessageConsumerManager(KafkaConfigProvider configProvider, Identity identity, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)
public KafkaMessageConsumerManager(KafkaConfigProvider configProvider)
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
public void afterPropertiesSet() throws Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
Exception
public Identity getIdentity()
public void setIdentity(Identity identity)
public TracerRegistry getTracerRegistry()
public void setTracerRegistry(TracerRegistry tracerRegistry)
public io.opentracing.Tracer getTracer()
public com.codahale.metrics.MetricRegistry getMetricRegistry()
public void setMetricRegistry(com.codahale.metrics.MetricRegistry metricRegistry)
Copyright © 2020. All rights reserved.