Interface ConsumerPauseResumeEventPublisher
-
- All Known Implementing Classes:
KafkaMessageListenerContainer
public interface ConsumerPauseResumeEventPublisherObjects that can publish consumer pause/resume events.- Since:
- 2.8.10
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidpublishConsumerPausedEvent(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions, java.lang.String reason)Publish a consumer paused event.voidpublishConsumerResumedEvent(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)Publish a consumer resumed event.
-
-
-
Method Detail
-
publishConsumerPausedEvent
void publishConsumerPausedEvent(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions, java.lang.String reason)Publish a consumer paused event.- Parameters:
partitions- the paused partitions.reason- the reason.
-
publishConsumerResumedEvent
void publishConsumerResumedEvent(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
Publish a consumer resumed event.- Parameters:
partitions- the resumed partitions.
-
-