Package com.linkedin.venice.controller.kafka.consumer

Class AdminConsumerService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.venice.controller.kafka.consumer.AdminConsumerService

All Implemented Interfaces:

Closeable, AutoCloseable

public class AdminConsumerService
extends AbstractVeniceService

One consumer service for one cluster.

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.service.AbstractVeniceService

AbstractVeniceService.ServiceState

Field Summary

Fields inherited from class com.linkedin.venice.service.AbstractVeniceService

logger, serviceState

Constructor Summary

Constructors

Constructor	Description
AdminConsumerService(VeniceHelixAdmin admin, VeniceControllerClusterConfig config, io.tehuti.metrics.MetricsRepository metricsRepository, PubSubConsumerAdapterFactory consumerFactory, PubSubTopicRepository pubSubTopicRepository, PubSubMessageDeserializer pubSubMessageDeserializer)

Method Summary

Modifier and Type	Method	Description
AdminMetadata	getAdminTopicMetadata(String clusterName)
PubSubMessageDeserializer	getDeserializer()
long	getFailingExecutionId()
PubSubPosition	getFailingPosition()
Exception	getLastExceptionForStore(String storeName)	Get the encountered exception during admin message consumption for the given store.
Long	getLastSucceededExecutionId(String storeName)	Get the last succeeded execution id for the given store.
Long	getLastSucceededExecutionIdInCluster(String clusterName)	Get the last succeeded execution id for the given cluster.
void	setExecutionIdToSkip(String clusterName, long executionId, boolean skipDIV)
void	setOffsetToSkip(String clusterName, long offset, boolean skipDIV)	Skip admin message with specified offset for the given cluster.
boolean	startInner()
void	stopInner()
void	updateAdminOperationProtocolVersion(String clusterName, long adminOperationProtocolVersion)	Update the admin operation protocol version for the given cluster.
void	updateAdminTopicMetadata(String clusterName, long executionId, long offset, long upstreamOffset)	Update cluster-level execution id, position, and upstream position in a child colo.

Methods inherited from class com.linkedin.venice.service.AbstractVeniceService

close, getName, isRunning, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

AdminConsumerService

public AdminConsumerService(VeniceHelixAdmin admin,
 VeniceControllerClusterConfig config,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 PubSubConsumerAdapterFactory consumerFactory,
 PubSubTopicRepository pubSubTopicRepository,
 PubSubMessageDeserializer pubSubMessageDeserializer)

Method Details

startInner

public boolean startInner()
                   throws Exception

Specified by:

startInner in class AbstractVeniceService

Returns:

true if the service is completely started, false if it is still starting asynchronously (in this case, it is the implementer's responsibility to set AbstractVeniceService.serviceState to AbstractVeniceService.ServiceState.STARTED upon completion of the async work).

Throws:

Exception

stopInner

public void stopInner()
               throws Exception

Specified by:

stopInner in class AbstractVeniceService

Throws:

Exception

setOffsetToSkip

public void setOffsetToSkip(String clusterName,
 long offset,
 boolean skipDIV)

Skip admin message with specified offset for the given cluster.

setExecutionIdToSkip

public void setExecutionIdToSkip(String clusterName,
 long executionId,
 boolean skipDIV)

getLastSucceededExecutionIdInCluster

public Long getLastSucceededExecutionIdInCluster(String clusterName)

Get the last succeeded execution id for the given cluster.

Parameters:

clusterName - name of the Venice cluster.

Returns:

last succeeded execution id for the given cluster.

getLastSucceededExecutionId

public Long getLastSucceededExecutionId(String storeName)

Get the last succeeded execution id for the given store.

Parameters:

storeName - name of the store.

Returns:

last succeeded execution id for the given store.

getLastExceptionForStore

public Exception getLastExceptionForStore(String storeName)

Get the encountered exception during admin message consumption for the given store.

Parameters:

storeName - name of the store.

Returns:

last encountered exception.

getFailingPosition

public PubSubPosition getFailingPosition()

Returns:

The first or the smallest failing position.

getFailingExecutionId

public long getFailingExecutionId()

Returns:

The first or the smallest failing execution id.

getAdminTopicMetadata

public AdminMetadata getAdminTopicMetadata(String clusterName)

Returns:

cluster-level execution id, position, and upstream position in a child colo.

updateAdminTopicMetadata

public void updateAdminTopicMetadata(String clusterName,
 long executionId,
 long offset,
 long upstreamOffset)

Update cluster-level execution id, position, and upstream position in a child colo.

updateAdminOperationProtocolVersion

public void updateAdminOperationProtocolVersion(String clusterName,
 long adminOperationProtocolVersion)

Update the admin operation protocol version for the given cluster.

getDeserializer

public PubSubMessageDeserializer getDeserializer()