Package org.springframework.kafka.event

Class ConsumerPartitionPausedEvent

java.lang.Object

java.util.EventObject

org.springframework.context.ApplicationEvent

org.springframework.kafka.event.KafkaEvent

org.springframework.kafka.event.ConsumerPartitionPausedEvent

All Implemented Interfaces:

Serializable

public class ConsumerPartitionPausedEvent
extends KafkaEvent

An event published when a consumer partition is paused.

Since:

2.7

Author:

Tomaz Fernandes, Borahm Lee

See Also:

• Serialized Form

Field Summary

Fields inherited from class java.util.EventObject

source

Constructor Summary

Constructors

Constructor	Description
ConsumerPartitionPausedEvent(Object source, Object container, org.apache.kafka.common.TopicPartition partition)	Construct an instance with the provided source and partition.

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.common.TopicPartition	getPartition()	Return the paused partition.
org.apache.kafka.common.TopicPartition	getPartitions()	Deprecated, for removal: This API element is subject to removal in a future version. replaced by getPartition()
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 Details

ConsumerPartitionPausedEvent

public ConsumerPartitionPausedEvent(Object source,
 Object container,
 org.apache.kafka.common.TopicPartition partition)

Construct an instance with the provided source and partition.

Parameters:

source - the container instance that generated the event.

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

partition - the partition.

Since:

2.7

Method Details

getPartitions

@Deprecated(since="3.3",
            forRemoval=true)
public org.apache.kafka.common.TopicPartition getPartitions()

Deprecated, for removal: This API element is subject to removal in a future version.

replaced by getPartition()

Return the paused partition.

Returns:

the partition.

getPartition

public org.apache.kafka.common.TopicPartition getPartition()

Return the paused partition.

Returns:

the partition.

Since:

3.3

toString

public String toString()

Overrides:

toString in class EventObject