Package io.eventuate.messaging.kafka.basic.consumer

Class BackPressureManagerNormalState

java.lang.Object

io.eventuate.messaging.kafka.basic.consumer.BackPressureManagerNormalState

All Implemented Interfaces:

BackPressureManagerState

public class BackPressureManagerNormalState
extends Object
implements BackPressureManagerState

Constructor Summary

Constructors

Constructor	Description
BackPressureManagerNormalState()

Method Summary

Modifier and Type	Method	Description
static BackPressureManagerStateAndActions	transitionTo(Set<org.apache.kafka.common.TopicPartition> suspendedPartitions)
BackPressureManagerStateAndActions	update(Set<org.apache.kafka.common.TopicPartition> allTopicPartitions, int backlog, BackPressureConfig backPressureConfig)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BackPressureManagerNormalState

public BackPressureManagerNormalState()

Method Details

transitionTo

public static BackPressureManagerStateAndActions transitionTo(Set<org.apache.kafka.common.TopicPartition> suspendedPartitions)

update

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

Specified by:

update in interface BackPressureManagerState