org.springframework.kafka.event

Class ConsumerPausedEvent

java.lang.Object

java.util.EventObject

org.springframework.context.ApplicationEvent

org.springframework.kafka.event.KafkaEvent

org.springframework.kafka.event.ConsumerPausedEvent

All Implemented Interfaces:

java.io.Serializable

public class ConsumerPausedEvent
extends KafkaEvent

An event published when a consumer is paused.

Since:

2.1.5

Author:

Gary Russell

See Also:

Serialized Form

Field Summary

Fields inherited from class java.util.EventObject

source

Constructor Summary

Constructors

Constructor and Description
ConsumerPausedEvent(java.lang.Object source, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions) Deprecated.
ConsumerPausedEvent(java.lang.Object source, java.lang.Object container, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions) Construct an instance with the provided source and partitions.

Method Summary

Modifier and Type	Method and Description
java.util.Collection<org.apache.kafka.common.TopicPartition>	getPartitions()
java.lang.String	toString()

Methods inherited from class org.springframework.kafka.event.KafkaEvent

getContainer, getSource

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

ConsumerPausedEvent

@Deprecated
public ConsumerPausedEvent(java.lang.Object source,
                                       java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)

Deprecated.

Construct an instance with the provided source and partitions.

Parameters:

source - the container.

partitions - the partitions.

ConsumerPausedEvent

public ConsumerPausedEvent(java.lang.Object source,
                           java.lang.Object container,
                           java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)

Construct an instance with the provided source and partitions.

Parameters:

source - the container instance that generated the event.

container - the container or the parent container if the container is a child.

partitions - the partitions.

Since:

2.2.1

Method Detail

getPartitions

public java.util.Collection<org.apache.kafka.common.TopicPartition> getPartitions()

toString

public java.lang.String toString()

Overrides:

toString in class java.util.EventObject