Package com.linkedin.davinci.kafka.consumer

Class MetadataRepoBasedStaleTopicCheckerImpl

java.lang.Object

com.linkedin.davinci.kafka.consumer.MetadataRepoBasedStaleTopicCheckerImpl

All Implemented Interfaces:

StaleTopicChecker

public class MetadataRepoBasedStaleTopicCheckerImpl
extends Object
implements StaleTopicChecker

Constructor Summary

Constructors

Constructor	Description
MetadataRepoBasedStaleTopicCheckerImpl(ReadOnlyStoreRepository readOnlyStoreRepository)

Method Summary

Modifier and Type	Method	Description
boolean	shouldTopicExist(String topic)

Methods inherited from class java.lang.Object

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

Constructor Details

MetadataRepoBasedStaleTopicCheckerImpl

public MetadataRepoBasedStaleTopicCheckerImpl(ReadOnlyStoreRepository readOnlyStoreRepository)

Method Details

shouldTopicExist

public boolean shouldTopicExist(String topic)

Specified by:

shouldTopicExist in interface StaleTopicChecker