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

Class AdminConsumptionTask

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class AdminConsumptionTask
extends Object
implements Runnable, 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 final int	IGNORED_CURRENT_VERSION

Constructor Summary

Constructors

Constructor

Description

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

Method Summary

Modifier and Type	Method	Description
void	close()
ExecutorService	getExecutorService()
void	run()

Methods inherited from class java.lang.Object

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

Field Details

IGNORED_CURRENT_VERSION

public static final int IGNORED_CURRENT_VERSION

See Also:

• Constant Field Values

Constructor Details

AdminConsumptionTask

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

Method Details

getExecutorService

public ExecutorService getExecutorService()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable