Package com.linkedin.davinci.kafka.consumer

Class MetadataRepoBasedTopicExistingCheckerImpl

java.lang.Object

com.linkedin.davinci.kafka.consumer.MetadataRepoBasedTopicExistingCheckerImpl

All Implemented Interfaces:

TopicExistenceChecker

public class MetadataRepoBasedTopicExistingCheckerImpl
extends Object
implements TopicExistenceChecker

Constructor Summary

Constructors

Constructor	Description
MetadataRepoBasedTopicExistingCheckerImpl(ReadOnlyStoreRepository readOnlyStoreRepository)

Method Summary

Modifier and Type	Method	Description
boolean	checkTopicExists(String topic)

Methods inherited from class java.lang.Object

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

Constructor Details

MetadataRepoBasedTopicExistingCheckerImpl

public MetadataRepoBasedTopicExistingCheckerImpl(ReadOnlyStoreRepository readOnlyStoreRepository)

Method Details

checkTopicExists

public boolean checkTopicExists(String topic)

Specified by:

checkTopicExists in interface TopicExistenceChecker