BackPressureManagerState (eventuate-messaging-kafka-basic-consumer 0.20.0.RELEASE API)

All Known Implementing Classes:: BackPressureManagerNormalState, BackPressureManagerPausedState

public interface BackPressureManagerState

Method Summary

Modifier and Type

Method

Description

BackPressureManagerStateAndActions

update(Set<org.apache.kafka.common.TopicPartition> allTopicPartitions, int backlog, BackPressureConfig backPressureConfig)

Method Details
- update
  
  BackPressureManagerStateAndActions update(Set<org.apache.kafka.common.TopicPartition> allTopicPartitions, int backlog, BackPressureConfig backPressureConfig)