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

Interface ConsumerPartitionRebalanceStrategy

All Known Implementing Classes:

ZKLeaderConsumerPartitionRebalanceStrategy

public interface ConsumerPartitionRebalanceStrategy

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ConsumerPartitionRebalanceStrategy.ResultCallback

Method Summary

Modifier and Type	Method and Description
void	rebalance(de.zalando.paradox.nakadi.consumer.core.domain.EventType eventType, ConsumerPartitionRebalanceStrategy.ResultCallback resultCallback)
void	setCurrentMembers(de.zalando.paradox.nakadi.consumer.core.domain.EventType eventType, java.util.Map<java.lang.String,ZKMember> currentMember)
void	setNakadiPartitions(de.zalando.paradox.nakadi.consumer.core.domain.EventType eventType, java.util.Collection<de.zalando.paradox.nakadi.consumer.core.domain.NakadiPartition> collection)

Method Detail

rebalance

void rebalance(de.zalando.paradox.nakadi.consumer.core.domain.EventType eventType,
               ConsumerPartitionRebalanceStrategy.ResultCallback resultCallback)

setNakadiPartitions

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

setCurrentMembers

void setCurrentMembers(de.zalando.paradox.nakadi.consumer.core.domain.EventType eventType,
                       java.util.Map<java.lang.String,ZKMember> currentMember)