Package com.linkedin.davinci.config

Class VeniceClusterConfig

java.lang.Object
com.linkedin.davinci.config.VeniceClusterConfig
Direct Known Subclasses:
VeniceServerConfig
public class VeniceClusterConfig extends Object
class that maintains config very specific to a Venice cluster

  • Constructor Details

  • Method Details

    • getClusterName

      public String getClusterName()

    • getZookeeperAddress

      public String getZookeeperAddress()

    • getPersistenceType

      public PersistenceType getPersistenceType()

    • getKafkaBootstrapServers

      public String getKafkaBootstrapServers()

    • getKafkaSecurityProtocol

      public PubSubSecurityProtocol getKafkaSecurityProtocol(String kafkaBootstrapUrl)

    • getSslConfig

      public Optional<SSLConfig> getSslConfig()

    • getRefreshIntervalForZkReconnectInMs

      public long getRefreshIntervalForZkReconnectInMs()

    • getRefreshAttemptsForZkReconnect

      public int getRefreshAttemptsForZkReconnect()

    • getKafkaReadCycleDelayMs

      public long getKafkaReadCycleDelayMs()

    • getKafkaEmptyPollSleepMs

      public long getKafkaEmptyPollSleepMs()

    • getKafkaFetchMinSizePerSecond

      public long getKafkaFetchMinSizePerSecond()

    • getKafkaFetchMaxSizePerSecond

      public long getKafkaFetchMaxSizePerSecond()

    • getKafkaFetchMaxTimeMS

      public long getKafkaFetchMaxTimeMS()

    • getKafkaFetchPartitionMaxSizePerSecond

      public long getKafkaFetchPartitionMaxSizePerSecond()

    • getKafkaFetchQuotaTimeWindow

      public long getKafkaFetchQuotaTimeWindow()

    • getKafkaFetchQuotaBytesPerSecond

      public long getKafkaFetchQuotaBytesPerSecond()

    • getKafkaFetchQuotaRecordPerSecond

      public long getKafkaFetchQuotaRecordPerSecond()

    • getKafkaFetchQuotaUnorderedBytesPerSecond

      public long getKafkaFetchQuotaUnorderedBytesPerSecond()

    • getKafkaFetchQuotaUnorderedRecordPerSecond

      public long getKafkaFetchQuotaUnorderedRecordPerSecond()

    • getRegionName

      public String getRegionName()

    • getKafkaClusterIdToUrlMap

      public it.unimi.dsi.fastutil.ints.Int2ObjectMap<String> getKafkaClusterIdToUrlMap()

    • getKafkaClusterUrlToIdMap

      public it.unimi.dsi.fastutil.objects.Object2IntMap<String> getKafkaClusterUrlToIdMap()

    • getKafkaClusterIdToAliasMap

      public it.unimi.dsi.fastutil.ints.Int2ObjectMap<String> getKafkaClusterIdToAliasMap()

    • getKafkaClusterAliasToIdMap

      public it.unimi.dsi.fastutil.objects.Object2IntMap<String> getKafkaClusterAliasToIdMap()

    • getKafkaClusterUrlToAliasMap

      public Map<String,String> getKafkaClusterUrlToAliasMap()

    • getKafkaClusterUrlResolver

      public Function<String,String> getKafkaClusterUrlResolver()
      Used to convert from an alternative Kafka URL to the one used in this server instance. For example, can be used in case of a URL migration, or a security protocol migration (e.g. from PLAINTEXT to SSL).

    • getRegionNames

      public Set<String> getRegionNames()

    • getClusterProperties

      public VeniceProperties getClusterProperties()

    • getKafkaClusterMap

      public Map<String,Map<String,String>> getKafkaClusterMap()

    • getEquivalentKafkaClusterIdForSepTopic

      public int getEquivalentKafkaClusterIdForSepTopic(int clusterId)
      For the separate incremental push topic feature, we need to resolve the cluster id to the original one for monitoring purposes as the incremental push topic essentially uses the same pubsub clusters as the regular push topic, though it appears to have a different cluster id
      Parameters:
      clusterId -
      Returns: