public class ConsumerStoppedEvent extends KafkaEvent
| Modifier and Type | Class and Description |
|---|---|
static class |
ConsumerStoppedEvent.Reason |
| Constructor and Description |
|---|
ConsumerStoppedEvent(java.lang.Object source)
Deprecated.
|
ConsumerStoppedEvent(java.lang.Object source,
java.lang.Object container)
Deprecated.
|
ConsumerStoppedEvent(java.lang.Object source,
java.lang.Object container,
ConsumerStoppedEvent.Reason reason)
Construct an instance with the provided source and container.
|
| Modifier and Type | Method and Description |
|---|---|
ConsumerStoppedEvent.Reason |
getReason()
Return the reason why the consumer was stopped.
|
java.lang.String |
toString() |
getContainer, getSource@Deprecated public ConsumerStoppedEvent(java.lang.Object source)
source - the container.@Deprecated
public ConsumerStoppedEvent(java.lang.Object source,
java.lang.Object container)
source - the container instance that generated the event.container - the container or the parent container if the container is a child.public ConsumerStoppedEvent(java.lang.Object source,
java.lang.Object container,
ConsumerStoppedEvent.Reason reason)
source - the container instance that generated the event.container - the container or the parent container if the container is a child.reason - the reason.public ConsumerStoppedEvent.Reason getReason()
public java.lang.String toString()
toString in class java.util.EventObject