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

Class ZKConsumerPartitionLeader

java.lang.Object

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

public class ZKConsumerPartitionLeader
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeGroupLeadership(T t)
java.lang.String	getConsumerName()
java.lang.String	getLeaderInfoPath(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)
java.lang.String	getLeaderSelectorPath(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)

Methods inherited from class java.lang.Object

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

Method Detail

getLeaderSelectorPath

public java.lang.String getLeaderSelectorPath(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)

getLeaderInfoPath

public java.lang.String getLeaderInfoPath(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)

closeGroupLeadership

public void closeGroupLeadership(T t)

close

public void close()

getConsumerName

public java.lang.String getConsumerName()