Class ConsumerPartitionPausedEvent

All Implemented Interfaces:
Serializable

public class ConsumerPartitionPausedEvent extends KafkaEvent
An event published when a consumer partition is paused.
Since:
2.7
Author:
Tomaz Fernandes
See Also:
  • Constructor Details

    • ConsumerPartitionPausedEvent

      public ConsumerPartitionPausedEvent(Object source, Object container, org.apache.kafka.common.TopicPartition partition)
      Construct an instance with the provided source and partition.
      Parameters:
      source - the container instance that generated the event.
      container - the container or the parent container if the container is a child.
      partition - the partition.
      Since:
      2.7
  • Method Details

    • getPartitions

      public org.apache.kafka.common.TopicPartition getPartitions()
      Return the paused partition.
      Returns:
      the partition.
    • toString

      public String toString()
      Overrides:
      toString in class EventObject