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

Class ZKLeaderConsumerPartitionCoordinator

java.lang.Object

de.zalando.paradox.nakadi.consumer.core.partitioned.impl.AbstractPartitionCoordinator

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

All Implemented Interfaces:

de.zalando.paradox.nakadi.consumer.core.partitioned.PartitionCommitCallbackProvider, de.zalando.paradox.nakadi.consumer.core.partitioned.PartitionCoordinator, de.zalando.paradox.nakadi.consumer.core.partitioned.PartitionOffsetManagement, de.zalando.paradox.nakadi.consumer.core.partitioned.PartitionRebalanceListenerProvider

public class ZKLeaderConsumerPartitionCoordinator
extends de.zalando.paradox.nakadi.consumer.core.partitioned.impl.AbstractPartitionCoordinator

Field Summary

Fields inherited from class de.zalando.paradox.nakadi.consumer.core.partitioned.impl.AbstractPartitionCoordinator

log

Constructor Summary

Constructors

Constructor and Description
ZKLeaderConsumerPartitionCoordinator(ZKHolder zkHolder, java.lang.String consumerName, java.util.List<de.zalando.paradox.nakadi.consumer.core.http.handlers.EventErrorHandler> eventErrorHandlers)

Method Summary

Modifier and Type	Method and Description
void	close()
void	commit(de.zalando.paradox.nakadi.consumer.core.domain.EventTypeCursor cursor)
void	error(int statusCode, java.lang.String content, de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)
void	error(java.lang.Throwable t, de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition, java.lang.String offset, java.lang.String rawEvent)
void	finished(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)
void	flush(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)
java.util.Optional<de.zalando.paradox.nakadi.consumer.core.partitioned.PartitionAdminService>	getAdminService()
java.lang.String	getConsumerName()
void	init()
void	rebalance(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartitions consumerPartitions, java.util.Collection<de.zalando.paradox.nakadi.consumer.core.domain.NakadiPartition> nakadiPartitions)
void	setDeleteUnavailableCursors(boolean deleteUnavailableCursors)
void	setStartNewestAvailableOffset(boolean startNewestAvailableOffset)

Methods inherited from class de.zalando.paradox.nakadi.consumer.core.partitioned.impl.AbstractPartitionCoordinator

assignPartition, assignPartitions, getPartitionCommitCallback, getPartitionRebalanceListener, getPartitions, getPartitionsToAssign, getPartitionsToRevoke, registerCommitCallback, registerRebalanceListener, revokePartition, revokePartitions, unregisterCommitCallback, unregisterRebalanceListener

Methods inherited from class java.lang.Object

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

Constructor Detail

ZKLeaderConsumerPartitionCoordinator

public ZKLeaderConsumerPartitionCoordinator(ZKHolder zkHolder,
                                            java.lang.String consumerName,
                                            java.util.List<de.zalando.paradox.nakadi.consumer.core.http.handlers.EventErrorHandler> eventErrorHandlers)

Method Detail

close

public void close()

init

public void init()

rebalance

public void rebalance(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartitions consumerPartitions,
                      java.util.Collection<de.zalando.paradox.nakadi.consumer.core.domain.NakadiPartition> nakadiPartitions)

finished

public void finished(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)

Specified by:

finished in interface de.zalando.paradox.nakadi.consumer.core.partitioned.PartitionCoordinator

Overrides:

finished in class de.zalando.paradox.nakadi.consumer.core.partitioned.impl.AbstractPartitionCoordinator

commit

public void commit(de.zalando.paradox.nakadi.consumer.core.domain.EventTypeCursor cursor)

flush

public void flush(de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)

error

public void error(java.lang.Throwable t,
                  de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition,
                  @Nullable
                  java.lang.String offset,
                  java.lang.String rawEvent)

error

public void error(int statusCode,
                  java.lang.String content,
                  de.zalando.paradox.nakadi.consumer.core.domain.EventTypePartition eventTypePartition)

setStartNewestAvailableOffset

public void setStartNewestAvailableOffset(boolean startNewestAvailableOffset)

setDeleteUnavailableCursors

public void setDeleteUnavailableCursors(boolean deleteUnavailableCursors)

getConsumerName

public java.lang.String getConsumerName()

getAdminService

public java.util.Optional<de.zalando.paradox.nakadi.consumer.core.partitioned.PartitionAdminService> getAdminService()