public class NonResponsiveConsumerEvent extends KafkaEvent
| Constructor and Description |
|---|
NonResponsiveConsumerEvent(java.lang.Object source,
long timeSinceLastPoll,
java.lang.String id,
java.util.Collection<org.apache.kafka.common.TopicPartition> topicPartitions,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Deprecated.
|
NonResponsiveConsumerEvent(java.lang.Object source,
java.lang.Object container,
long timeSinceLastPoll,
java.lang.String id,
java.util.Collection<org.apache.kafka.common.TopicPartition> topicPartitions,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Construct an instance with the provided properties.
|
| Modifier and Type | Method and Description |
|---|---|
org.apache.kafka.clients.consumer.Consumer<?,?> |
getConsumer()
Retrieve the consumer.
|
java.lang.String |
getListenerId()
The id of the listener (if
@KafkaListener) or the container bean name. |
long |
getTimeSinceLastPoll()
How long since the last poll.
|
java.util.Collection<org.apache.kafka.common.TopicPartition> |
getTopicPartitions()
The TopicPartitions the container is listening to.
|
java.lang.String |
toString() |
getContainer, getSource@Deprecated
public NonResponsiveConsumerEvent(java.lang.Object source,
long timeSinceLastPoll,
java.lang.String id,
java.util.Collection<org.apache.kafka.common.TopicPartition> topicPartitions,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
public NonResponsiveConsumerEvent(java.lang.Object source,
java.lang.Object container,
long timeSinceLastPoll,
java.lang.String id,
java.util.Collection<org.apache.kafka.common.TopicPartition> topicPartitions,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
source - the container instance that generated the event.container - the container or the parent container if the container is a child.timeSinceLastPoll - the time since the last poll.id - the container id.topicPartitions - the topic partitions.consumer - the consumer.public long getTimeSinceLastPoll()
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