K
- the key type.V
- the value type.public class ConcurrentMessageListenerContainer<K,V> extends AbstractMessageListenerContainer<K,V>
KafkaMessageListenerContainer
s based on
concurrency
. If the
ContainerProperties
is configured with TopicPartition
s,
the TopicPartition
s are distributed evenly across the
instances.consumerFactory, DEFAULT_PHASE, lifecycleMonitor, logger
Constructor and Description |
---|
ConcurrentMessageListenerContainer(ConsumerFactory<? super K,? super 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) |
java.util.Collection<org.apache.kafka.common.TopicPartition> |
getAssignedPartitions()
Return the assigned topics/partitions for this container.
|
java.util.Map<java.lang.String,java.util.Collection<org.apache.kafka.common.TopicPartition>> |
getAssignmentsByClientId()
Return the assigned topics/partitions for this container, by client.id.
|
int |
getConcurrency() |
java.util.List<KafkaMessageListenerContainer<K,V>> |
getContainers()
Return the list of
KafkaMessageListenerContainer s created by
this container. |
boolean |
isContainerPaused()
Return true if
MessageListenerContainer.pause() has been called; and all consumers in this container
have actually paused. |
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 |
pause()
Pause this container before the next poll().
|
void |
resume()
Resume this container, if paused, after the next poll().
|
void |
setAlwaysClientIdSuffix(boolean alwaysClientIdSuffix)
Set to false to suppress adding a suffix to the child container's client.id when
the concurrency is only 1.
|
void |
setConcurrency(int concurrency)
The maximum number of concurrent
KafkaMessageListenerContainer s running. |
java.lang.String |
toString() |
checkGroupId, checkTopics, createSimpleLoggingConsumerRebalanceListener, getAfterRollbackProcessor, getApplicationContext, getApplicationEventPublisher, getBeanName, getContainerProperties, getGenericErrorHandler, getGroupId, getListenerId, getPhase, getRecordInterceptor, isAutoStartup, isInterceptBeforeTx, isPaused, isPauseRequested, isRunning, parentOrThis, publishContainerStoppedEvent, setAfterRollbackProcessor, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setBatchErrorHandler, setBeanName, setErrorHandler, setGenericErrorHandler, setInterceptBeforeTx, setPhase, setRecordInterceptor, setRunning, setTopicCheckTimeout, setupMessageListener, start, stop, stop, stop
public ConcurrentMessageListenerContainer(ConsumerFactory<? super K,? super V> consumerFactory, ContainerProperties containerProperties)
KafkaMessageListenerContainer
s.consumerFactory
- the consumer factory.containerProperties
- the container properties.public int getConcurrency()
public void setConcurrency(int concurrency)
KafkaMessageListenerContainer
s running.
Messages from within the same partition will be processed sequentially.concurrency
- the concurrency.public void setAlwaysClientIdSuffix(boolean alwaysClientIdSuffix)
alwaysClientIdSuffix
- false to suppress, true (default) to include.public java.util.List<KafkaMessageListenerContainer<K,V>> getContainers()
KafkaMessageListenerContainer
s created by
this container.KafkaMessageListenerContainer
s created by
this container.public java.util.Collection<org.apache.kafka.common.TopicPartition> getAssignedPartitions()
MessageListenerContainer
public java.util.Map<java.lang.String,java.util.Collection<org.apache.kafka.common.TopicPartition>> getAssignmentsByClientId()
MessageListenerContainer
public boolean isContainerPaused()
MessageListenerContainer
MessageListenerContainer.pause()
has been called; and all consumers in this container
have actually paused.public java.util.Map<java.lang.String,java.util.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>> metrics()
MessageListenerContainer
client-id
.client-id
Consumer.metrics()
protected void doStart()
doStart
in class AbstractMessageListenerContainer<K,V>
protected void doStop(java.lang.Runnable callback)
doStop
in class AbstractMessageListenerContainer<K,V>
public void pause()
MessageListenerContainer
pause
in interface MessageListenerContainer
pause
in class AbstractMessageListenerContainer<K,V>
public void resume()
MessageListenerContainer
resume
in interface MessageListenerContainer
resume
in class AbstractMessageListenerContainer<K,V>
public java.lang.String toString()
toString
in class java.lang.Object