public class ListenerContainerIdleEvent extends KafkaEvent
Constructor and Description |
---|
ListenerContainerIdleEvent(java.lang.Object source,
long idleTime,
java.lang.String id,
java.util.Collection<org.apache.kafka.common.TopicPartition> topicPartitions,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.Consumer<?,?> |
getConsumer()
Retrieve the consumer.
|
long |
getIdleTime()
How long the container has been idle.
|
java.lang.String |
getListenerId()
The id of the listener (if
@KafkaListener ) or the container bean name. |
java.util.Collection<org.apache.kafka.common.TopicPartition> |
getTopicPartitions()
The TopicPartitions the container is listening to.
|
java.lang.String |
toString() |
public ListenerContainerIdleEvent(java.lang.Object source, long idleTime, java.lang.String id, java.util.Collection<org.apache.kafka.common.TopicPartition> topicPartitions, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
public long getIdleTime()
public java.util.Collection<org.apache.kafka.common.TopicPartition> getTopicPartitions()
public java.lang.String getListenerId()
@KafkaListener
) or the container bean name.public org.apache.kafka.clients.consumer.Consumer<?,?> getConsumer()
public java.lang.String toString()
toString
in class java.util.EventObject