Package com.linkedin.venice.controller

Class VeniceControllerClusterConfig

  • Direct Known Subclasses:
    VeniceControllerConfig
    public class VeniceControllerClusterConfig
extends java.lang.Object
    Configuration which is specific to a Venice cluster used by Venice controller.

    • Constructor Detail

      • VeniceControllerClusterConfig

        public VeniceControllerClusterConfig​(VeniceProperties props)

    • Method Detail

      • isErrorLeaderReplicaFailOverEnabled

        public boolean isErrorLeaderReplicaFailOverEnabled()

      • getDefaultReadQuotaPerRouter

        public int getDefaultReadQuotaPerRouter()

      • getClusterName

        public java.lang.String getClusterName()

      • getZkAddress

        public final java.lang.String getZkAddress()

      • getControllerName

        public java.lang.String getControllerName()

      • getReplicationFactor

        public int getReplicationFactor()

      • getMinNumberOfPartitions

        public int getMinNumberOfPartitions()

      • getMinNumberOfPartitionsForHybrid

        public int getMinNumberOfPartitionsForHybrid()

      • getKafkaReplicationFactor

        public int getKafkaReplicationFactor()

      • getKafkaReplicationFactorRTTopics

        public int getKafkaReplicationFactorRTTopics()

      • getPartitionSize

        public long getPartitionSize()

      • isDisableParentRequestTopicForStreamPushes

        public boolean isDisableParentRequestTopicForStreamPushes()

      • getMaxNumberOfPartitions

        public int getMaxNumberOfPartitions()

      • isPartitionCountRoundUpEnabled

        public boolean isPartitionCountRoundUpEnabled()

      • getPartitionCountRoundUpSize

        public int getPartitionCountRoundUpSize()

      • getOffLineJobWaitTimeInMilliseconds

        public long getOffLineJobWaitTimeInMilliseconds()

      • getDelayToRebalanceMS

        public long getDelayToRebalanceMS()

      • getMinActiveReplica

        @Deprecated
public int getMinActiveReplica()
        Deprecated.

      • getKafkaBootstrapServers

        public java.lang.String getKafkaBootstrapServers()
        Returns:
        kafka Bootstrap Urls. If there is more than one url, they are separated by commas.

      • getClusterToD2Map

        public java.util.Map<java.lang.String,​java.lang.String> getClusterToD2Map()

      • getClusterToServerD2Map

        public java.util.Map<java.lang.String,​java.lang.String> getClusterToServerD2Map()

      • isSslToKafka

        public boolean isSslToKafka()

      • getSslKafkaBootstrapServers

        public java.lang.String getSslKafkaBootstrapServers()

      • getHelixSendMessageTimeoutMs

        public int getHelixSendMessageTimeoutMs()

      • getKafkaSecurityProtocol

        public java.lang.String getKafkaSecurityProtocol()

      • getSslConfig

        public java.util.Optional<SSLConfig> getSslConfig()

      • getSslFactoryClassName

        public java.lang.String getSslFactoryClassName()

      • getRefreshAttemptsForZkReconnect

        public int getRefreshAttemptsForZkReconnect()

      • getRefreshIntervalForZkReconnectInMs

        public long getRefreshIntervalForZkReconnectInMs()

      • isEnableOfflinePushSSLAllowlist

        public boolean isEnableOfflinePushSSLAllowlist()

      • getPushSSLAllowlist

        public java.util.List<java.lang.String> getPushSSLAllowlist()

      • isEnableNearlinePushSSLAllowlist

        public boolean isEnableNearlinePushSSLAllowlist()

      • getHelixRebalanceAlg

        public java.lang.String getHelixRebalanceAlg()

      • getAdminTopicReplicationFactor

        public int getAdminTopicReplicationFactor()

      • getMinInSyncReplicas

        public java.util.Optional<java.lang.Integer> getMinInSyncReplicas()

      • getMinInSyncReplicasRealTimeTopics

        public java.util.Optional<java.lang.Integer> getMinInSyncReplicasRealTimeTopics()

      • getMinInSyncReplicasAdminTopics

        public java.util.Optional<java.lang.Integer> getMinInSyncReplicasAdminTopics()

      • isKafkaLogCompactionForHybridStoresEnabled

        public boolean isKafkaLogCompactionForHybridStoresEnabled()

      • getKafkaMinLogCompactionLagInMs

        public long getKafkaMinLogCompactionLagInMs()

      • isNativeReplicationEnabledForBatchOnly

        public boolean isNativeReplicationEnabledForBatchOnly()

      • isNativeReplicationEnabledAsDefaultForBatchOnly

        public boolean isNativeReplicationEnabledAsDefaultForBatchOnly()

      • isNativeReplicationEnabledForHybrid

        public boolean isNativeReplicationEnabledForHybrid()

      • isNativeReplicationEnabledAsDefaultForHybrid

        public boolean isNativeReplicationEnabledAsDefaultForHybrid()

      • isActiveActiveReplicationEnabledAsDefaultForBatchOnly

        public boolean isActiveActiveReplicationEnabledAsDefaultForBatchOnly()

      • isActiveActiveReplicationEnabledAsDefaultForHybrid

        public boolean isActiveActiveReplicationEnabledAsDefaultForHybrid()

      • isControllerSchemaValidationEnabled

        public boolean isControllerSchemaValidationEnabled()

      • getLeakedPushStatusCleanUpServiceSleepIntervalInMs

        public long getLeakedPushStatusCleanUpServiceSleepIntervalInMs()

      • getLeakedResourceAllowedLingerTimeInMs

        public long getLeakedResourceAllowedLingerTimeInMs()

      • getNativeReplicationSourceFabricAsDefaultForBatchOnly

        public java.lang.String getNativeReplicationSourceFabricAsDefaultForBatchOnly()

      • getNativeReplicationSourceFabricAsDefaultForHybrid

        public java.lang.String getNativeReplicationSourceFabricAsDefaultForHybrid()

      • getReplicationMetadataVersion

        public int getReplicationMetadataVersion()

      • getChildDatacenters

        public java.lang.String getChildDatacenters()

      • enabledIncrementalPushForHybridActiveActiveUserStores

        public boolean enabledIncrementalPushForHybridActiveActiveUserStores()

      • isEnablePartialUpdateForHybridActiveActiveUserStores

        public boolean isEnablePartialUpdateForHybridActiveActiveUserStores()

      • isEnablePartialUpdateForHybridNonActiveActiveUserStores

        public boolean isEnablePartialUpdateForHybridNonActiveActiveUserStores()