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

Class AdminConsumptionTask

java.lang.Object

com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Runnable

public class AdminConsumptionTask
extends java.lang.Object
implements java.lang.Runnable, java.io.Closeable

This class is used to create a task, which will consume the admin messages from the special admin topics.

Field Summary

Fields

Modifier and Type	Field	Description
static int	IGNORED_CURRENT_VERSION

Constructor Summary

Constructors

Constructor

Description

AdminConsumptionTask(java.lang.String clusterName, PubSubConsumerAdapter consumer, boolean remoteConsumptionEnabled, java.util.Optional<java.lang.String> remoteKafkaServerUrl, VeniceHelixAdmin admin, AdminTopicMetadataAccessor adminTopicMetadataAccessor, ExecutionIdAccessor executionIdAccessor, boolean isParentController, AdminConsumptionStats stats, int adminTopicReplicationFactor, java.util.Optional<java.lang.Integer> minInSyncReplicas, long processingCycleTimeoutInMs, int maxWorkerThreadPoolSize, PubSubTopicRepository pubSubTopicRepository, PubSubMessageDeserializer pubSubMessageDeserializer, java.lang.String regionName)

Method Summary

Modifier and Type	Method	Description
void	close()
java.util.concurrent.ExecutorService	getExecutorService()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

IGNORED_CURRENT_VERSION

public static final int IGNORED_CURRENT_VERSION

See Also:

Constant Field Values

Constructor Detail

AdminConsumptionTask

public AdminConsumptionTask(java.lang.String clusterName,
                            PubSubConsumerAdapter consumer,
                            boolean remoteConsumptionEnabled,
                            java.util.Optional<java.lang.String> remoteKafkaServerUrl,
                            VeniceHelixAdmin admin,
                            AdminTopicMetadataAccessor adminTopicMetadataAccessor,
                            ExecutionIdAccessor executionIdAccessor,
                            boolean isParentController,
                            AdminConsumptionStats stats,
                            int adminTopicReplicationFactor,
                            java.util.Optional<java.lang.Integer> minInSyncReplicas,
                            long processingCycleTimeoutInMs,
                            int maxWorkerThreadPoolSize,
                            PubSubTopicRepository pubSubTopicRepository,
                            PubSubMessageDeserializer pubSubMessageDeserializer,
                            java.lang.String regionName)

Method Detail

getExecutorService

public java.util.concurrent.ExecutorService getExecutorService()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException

run

public void run()

Specified by:

run in interface java.lang.Runnable