Interface ConsumerPauseResumeEventPublisher
- All Known Implementing Classes:
KafkaMessageListenerContainer
public interface ConsumerPauseResumeEventPublisher
Objects that can publish consumer pause/resume events.
- Since:
- 2.8.10
-
Method Summary
Modifier and TypeMethodDescriptionvoidpublishConsumerPausedEvent(Collection<org.apache.kafka.common.TopicPartition> partitions, String reason) Publish a consumer paused event.voidpublishConsumerResumedEvent(Collection<org.apache.kafka.common.TopicPartition> partitions) Publish a consumer resumed event.
-
Method Details
-
publishConsumerPausedEvent
void publishConsumerPausedEvent(Collection<org.apache.kafka.common.TopicPartition> partitions, String reason) Publish a consumer paused event.- Parameters:
partitions- the paused partitions.reason- the reason.
-
publishConsumerResumedEvent
Publish a consumer resumed event.- Parameters:
partitions- the resumed partitions.
-