Class ConsumerStoppedEvent

All Implemented Interfaces:
Serializable

public class ConsumerStoppedEvent 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. You can also use this event to restart a container that was stopped because a transactional producer was fenced.
Since:
2.2
Author:
Gary Russell
See Also:
  • Constructor Details

    • ConsumerStoppedEvent

      public ConsumerStoppedEvent(Object source, Object container, ConsumerStoppedEvent.Reason reason)
      Construct an instance with the provided source and container.
      Parameters:
      source - the container instance that generated the event.
      container - the container or the parent container if the container is a child.
      reason - the reason.
      Since:
      2.5.8
  • Method Details