Class TopicManagerContext.Builder
java.lang.Object
com.linkedin.venice.pubsub.manager.TopicManagerContext.Builder
- Enclosing class:
- TopicManagerContext
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbuild()
setMetricsRepository
(io.tehuti.metrics.MetricsRepository metricsRepository) setPubSubAdminAdapterFactory
(PubSubAdminAdapterFactory<PubSubAdminAdapter> pubSubAdminAdapterFactory) setPubSubConsumerAdapterFactory
(PubSubConsumerAdapterFactory<PubSubConsumerAdapter> pubSubConsumerAdapterFactory) setPubSubOperationTimeoutMs
(long pubSubOperationTimeoutMs) setPubSubPositionTypeRegistry
(PubSubPositionTypeRegistry pubSubPositionTypeRegistry) setPubSubPropertiesSupplier
(TopicManagerContext.PubSubPropertiesSupplier pubSubPropertiesSupplier) setPubSubTopicRepository
(PubSubTopicRepository pubSubTopicRepository) setTopicDeletionStatusPollIntervalMs
(long topicDeletionStatusPollIntervalMs) setTopicMetadataFetcherConsumerPoolSize
(int topicMetadataFetcherConsumerPoolSize) setTopicMetadataFetcherThreadPoolSize
(int topicMetadataFetcherThreadPoolSize) setTopicMinLogCompactionLagMs
(long topicMinLogCompactionLagMs) setTopicOffsetCheckIntervalMs
(long topicOffsetCheckIntervalMs) setVeniceComponent
(VeniceComponent veniceComponent) void
verify()
-
Constructor Details
-
Builder
public Builder()
-
-
Method Details
-
setPubSubOperationTimeoutMs
-
setTopicDeletionStatusPollIntervalMs
public TopicManagerContext.Builder setTopicDeletionStatusPollIntervalMs(long topicDeletionStatusPollIntervalMs) -
setTopicMinLogCompactionLagMs
-
setPubSubAdminAdapterFactory
public TopicManagerContext.Builder setPubSubAdminAdapterFactory(PubSubAdminAdapterFactory<PubSubAdminAdapter> pubSubAdminAdapterFactory) -
setPubSubConsumerAdapterFactory
public TopicManagerContext.Builder setPubSubConsumerAdapterFactory(PubSubConsumerAdapterFactory<PubSubConsumerAdapter> pubSubConsumerAdapterFactory) -
setPubSubTopicRepository
public TopicManagerContext.Builder setPubSubTopicRepository(PubSubTopicRepository pubSubTopicRepository) -
setPubSubPositionTypeRegistry
public TopicManagerContext.Builder setPubSubPositionTypeRegistry(PubSubPositionTypeRegistry pubSubPositionTypeRegistry) -
setMetricsRepository
public TopicManagerContext.Builder setMetricsRepository(io.tehuti.metrics.MetricsRepository metricsRepository) -
setPubSubPropertiesSupplier
public TopicManagerContext.Builder setPubSubPropertiesSupplier(TopicManagerContext.PubSubPropertiesSupplier pubSubPropertiesSupplier) -
setTopicOffsetCheckIntervalMs
-
setTopicMetadataFetcherConsumerPoolSize
public TopicManagerContext.Builder setTopicMetadataFetcherConsumerPoolSize(int topicMetadataFetcherConsumerPoolSize) -
setTopicMetadataFetcherThreadPoolSize
public TopicManagerContext.Builder setTopicMetadataFetcherThreadPoolSize(int topicMetadataFetcherThreadPoolSize) -
setVeniceComponent
-
verify
public void verify() -
build
-