Class TopicManagerContext


  • public class TopicManagerContext
    extends java.lang.Object
    A context object that contains all the dependencies needed by TopicManager.
    • Method Detail

      • getPubSubOperationTimeoutMs

        public long getPubSubOperationTimeoutMs()
      • getTopicDeletionStatusPollIntervalMs

        public long getTopicDeletionStatusPollIntervalMs()
      • getTopicMinLogCompactionLagMs

        public long getTopicMinLogCompactionLagMs()
      • getMetricsRepository

        public io.tehuti.metrics.MetricsRepository getMetricsRepository()
      • getPubSubProperties

        public VeniceProperties getPubSubProperties​(java.lang.String pubSubBootstrapServers)
      • getTopicOffsetCheckIntervalMs

        public long getTopicOffsetCheckIntervalMs()
      • getTopicMetadataFetcherConsumerPoolSize

        public int getTopicMetadataFetcherConsumerPoolSize()
      • getTopicMetadataFetcherThreadPoolSize

        public int getTopicMetadataFetcherThreadPoolSize()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object