K - the key type.V - the value type.public class ConcurrentMessageListenerContainer<K,V> extends AbstractMessageListenerContainer<K,V>
KafkaMessageListenerContainers based on
concurrency. If the
ContainerProperties is configured with TopicPartitions,
the TopicPartitions are distributed evenly across the
instances.AbstractMessageListenerContainer.AckModeDEFAULT_PHASE, logger| Constructor and Description |
|---|
ConcurrentMessageListenerContainer(ConsumerFactory<K,V> consumerFactory,
ContainerProperties containerProperties)
Construct an instance with the supplied configuration properties.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart() |
protected void |
doStop(java.lang.Runnable callback) |
int |
getConcurrency() |
java.util.List<KafkaMessageListenerContainer<K,V>> |
getContainers()
Return the list of
KafkaMessageListenerContainers created by
this container. |
java.util.Map<java.lang.String,java.util.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>> |
metrics()
Return metrics kept by this container's consumer(s), grouped by
client-id. |
void |
setConcurrency(int concurrency)
The maximum number of concurrent
KafkaMessageListenerContainers running. |
java.lang.String |
toString() |
createSimpleLoggingConsumerRebalanceListener, getAfterRollbackProcessor, getApplicationEventPublisher, getBeanName, getContainerProperties, getPhase, isAutoStartup, isRunning, setAfterRollbackProcessor, setApplicationEventPublisher, setAutoStartup, setBeanName, setPhase, setRunning, setupMessageListener, start, stop, stoppublic ConcurrentMessageListenerContainer(ConsumerFactory<K,V> consumerFactory, ContainerProperties containerProperties)
KafkaMessageListenerContainers.consumerFactory - the consumer factory.containerProperties - the container properties.public int getConcurrency()
public void setConcurrency(int concurrency)
KafkaMessageListenerContainers running.
Messages from within the same partition will be processed sequentially.concurrency - the concurrency.public java.util.List<KafkaMessageListenerContainer<K,V>> getContainers()
KafkaMessageListenerContainers created by
this container.KafkaMessageListenerContainers created by
this container.public java.util.Map<java.lang.String,java.util.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>> metrics()
MessageListenerContainerclient-id.client-idConsumer.metrics()protected void doStart()
doStart in class AbstractMessageListenerContainer<K,V>protected void doStop(java.lang.Runnable callback)
doStop in class AbstractMessageListenerContainer<K,V>public java.lang.String toString()
toString in class java.lang.Object