org.springframework.kafka.event

Class ConsumerStoppedEvent

java.lang.Object

java.util.EventObject

org.springframework.context.ApplicationEvent

org.springframework.kafka.event.KafkaEvent

org.springframework.kafka.event.ConsumerStoppedEvent

All Implemented Interfaces:

java.io.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.

Since:

2.2

Author:

Gary Russell

See Also:

Serialized Form

Field Summary

Fields inherited from class java.util.EventObject

source

Constructor Summary

Constructors

Constructor and Description
ConsumerStoppedEvent(java.lang.Object source) Construct an instance with the provided source and partitions.

Method Summary

Modifier and Type	Method and Description
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

ConsumerStoppedEvent

public ConsumerStoppedEvent(java.lang.Object source)

Construct an instance with the provided source and partitions.

Parameters:

source - the container.

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.util.EventObject