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

Class BackPressureActions

java.lang.Object

io.eventuate.messaging.kafka.basic.consumer.BackPressureActions

public class BackPressureActions
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final BackPressureActions	NONE
final Set<org.apache.kafka.common.TopicPartition>	pause
final Set<org.apache.kafka.common.TopicPartition>	resume

Constructor Summary

Constructors

Constructor	Description
BackPressureActions(Set<org.apache.kafka.common.TopicPartition> pause, Set<org.apache.kafka.common.TopicPartition> resume)

Method Summary

Modifier and Type	Method	Description
static BackPressureActions	pause(Set<org.apache.kafka.common.TopicPartition> topicPartitions)
static BackPressureActions	resume(Set<org.apache.kafka.common.TopicPartition> topicPartitions)

Methods inherited from class java.lang.Object

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

Field Details

pause

public final Set<org.apache.kafka.common.TopicPartition> pause

resume

public final Set<org.apache.kafka.common.TopicPartition> resume

NONE

public static final BackPressureActions NONE

Constructor Details

BackPressureActions

public BackPressureActions(Set<org.apache.kafka.common.TopicPartition> pause,
 Set<org.apache.kafka.common.TopicPartition> resume)

Method Details

pause

public static BackPressureActions pause(Set<org.apache.kafka.common.TopicPartition> topicPartitions)

resume

public static BackPressureActions resume(Set<org.apache.kafka.common.TopicPartition> topicPartitions)