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

Class ZKSimpleConsumerPartitionCoordinator

java.lang.Object

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

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

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 ZKSimpleConsumerPartitionCoordinator
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
ZKSimpleConsumerPartitionCoordinator(ZKHolder zkHolder, java.lang.String consumerName, java.util.List<de.zalando.paradox.nakadi.consumer.core.http.handlers.EventErrorHandler> eventErrorHandlerList)

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	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, finished, 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

ZKSimpleConsumerPartitionCoordinator

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

Method Detail

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)

init

public void init()

close

public void close()

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()