de.zalando.paradox.nakadi.consumer.partitioned.zk

Interface ConsumerPartitionRebalanceStrategy.ResultCallback

Enclosing interface:

ConsumerPartitionRebalanceStrategy

public static interface ConsumerPartitionRebalanceStrategy.ResultCallback

Method Summary

Modifier and Type	Method and Description
void	rebalancePartitions(de.zalando.paradox.nakadi.consumer.core.domain.EventType eventType, java.util.Collection<de.zalando.paradox.nakadi.consumer.core.domain.NakadiPartition> partitionsToAssign, java.util.Collection<de.zalando.paradox.nakadi.consumer.core.domain.NakadiPartition> partitionsToRevoke)

Method Detail

rebalancePartitions

void rebalancePartitions(de.zalando.paradox.nakadi.consumer.core.domain.EventType eventType,
                         java.util.Collection<de.zalando.paradox.nakadi.consumer.core.domain.NakadiPartition> partitionsToAssign,
                         java.util.Collection<de.zalando.paradox.nakadi.consumer.core.domain.NakadiPartition> partitionsToRevoke)