Package com.linkedin.venice.controller.kafka

Class TopicCleanupServiceForParentController

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.venice.controller.kafka.TopicCleanupService

com.linkedin.venice.controller.kafka.TopicCleanupServiceForParentController

All Implemented Interfaces:

Closeable, AutoCloseable

public class TopicCleanupServiceForParentController
extends TopicCleanupService

In parent controller, TopicCleanupServiceForParentController will remove all the deprecated topics: topic with low retention policy.

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.controller.kafka.TopicCleanupService

delayFactor, multiClusterConfigs, sleepIntervalBetweenTopicListFetchMs, topicPriorityComparator

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

logger, serviceState

Constructor Summary

Constructors

Constructor	Description
TopicCleanupServiceForParentController(Admin admin, VeniceControllerMultiClusterConfig multiClusterConfigs, PubSubTopicRepository pubSubTopicRepository, TopicCleanupServiceStats topicCleanupServiceStats, PubSubClientsFactory pubSubClientsFactory)

Method Summary

Modifier and Type	Method	Description
protected void	cleanupVeniceTopics()

Methods inherited from class com.linkedin.venice.controller.kafka.TopicCleanupService

extractVersionTopicsToCleanup, getAllVeniceStoreTopicsRetentions, startInner, stopInner

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

TopicCleanupServiceForParentController

public TopicCleanupServiceForParentController(Admin admin,
 VeniceControllerMultiClusterConfig multiClusterConfigs,
 PubSubTopicRepository pubSubTopicRepository,
 TopicCleanupServiceStats topicCleanupServiceStats,
 PubSubClientsFactory pubSubClientsFactory)

Method Details

cleanupVeniceTopics

protected void cleanupVeniceTopics()