Class ConsumerPausedEvent

All Implemented Interfaces:
Serializable

public class ConsumerPausedEvent extends KafkaEvent
An event published when a consumer is paused.
Since:
2.1.5
Author:
Gary Russell
See Also:
  • Constructor Details

    • ConsumerPausedEvent

      public ConsumerPausedEvent(Object source, Object container, Collection<org.apache.kafka.common.TopicPartition> partitions)
      Construct an instance with the provided source and partitions.
      Parameters:
      source - the container instance that generated the event.
      container - the container or the parent container if the container is a child.
      partitions - the partitions.
      Since:
      2.2.1
    • ConsumerPausedEvent

      public ConsumerPausedEvent(Object source, Object container, Collection<org.apache.kafka.common.TopicPartition> partitions, String reason)
      Construct an instance with the provided source and partitions.
      Parameters:
      source - the container instance that generated the event.
      container - the container or the parent container if the container is a child.
      partitions - the partitions.
      reason - the reason for the pause.
      Since:
      2.8.9
  • Method Details

    • getPartitions

      public Collection<org.apache.kafka.common.TopicPartition> getPartitions()
      Return the paused partitions.
      Returns:
      the partitions.
    • toString

      public String toString()
      Overrides:
      toString in class EventObject