Class ConsumerPartitionPausedEvent

  • All Implemented Interfaces:
    java.io.Serializable

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

      • Fields inherited from class java.util.EventObject

        source
    • Constructor Summary

      Constructors 
      Constructor Description
      ConsumerPartitionPausedEvent​(java.lang.Object source, java.lang.Object container, org.apache.kafka.common.TopicPartition partition)
      Construct an instance with the provided source and partition.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.kafka.common.TopicPartition getPartitions()
      Return the paused partition.
      java.lang.String toString()  
      • Methods inherited from class org.springframework.context.ApplicationEvent

        getTimestamp
      • Methods inherited from class java.util.EventObject

        getSource
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • ConsumerPartitionPausedEvent

        public ConsumerPartitionPausedEvent​(java.lang.Object source,
                                            java.lang.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 Detail

      • getPartitions

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

        public java.lang.String toString()
        Overrides:
        toString in class java.util.EventObject