Class ConsumerStoppingEvent

All Implemented Interfaces:
Serializable

public class ConsumerStoppingEvent extends KafkaEvent
An event published when a consumer is stopped. While it is best practice to use stateless listeners, you can consume this event to clean up any thread-based resources (remove ThreadLocals, destroy thread-scoped beans etc), as long as the context event multicaster is not modified to use an async task executor.
Since:
2.2
Author:
Gary Russell
See Also:
  • Constructor Details

    • ConsumerStoppingEvent

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

    • getConsumer

      public org.apache.kafka.clients.consumer.Consumer<?,?> getConsumer()
    • getPartitions

      public Collection<org.apache.kafka.common.TopicPartition> getPartitions()
    • toString

      public String toString()
      Overrides:
      toString in class EventObject