LiveClusterConfig (venice API)

java.lang.Object

com.linkedin.venice.meta.LiveClusterConfig

public class LiveClusterConfig extends Object

Field Summary

Fields

Modifier and Type

Field

Description

static final int

DEFAULT_SERVER_KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND
Constructor Summary

Constructors

Constructor

Description

LiveClusterConfig()

LiveClusterConfig(LiveClusterConfig clone)
Method Summary

Modifier and Type

Method

Description

Map<String,Integer>

getServerKafkaFetchQuotaRecordsPerSecond()

int

getServerKafkaFetchQuotaRecordsPerSecondForRegion(String regionName)

boolean

isChildControllerAdminTopicConsumptionEnabled()

boolean

isStoreMigrationAllowed()

void

setChildControllerAdminTopicConsumptionEnabled(boolean childControllerAdminTopicConsumptionEnabled)

void

setServerKafkaFetchQuotaRecordsPerSecond(Map<String,Integer> serverKafkaFetchQuotaRecordsPerSecond)

void

setServerKafkaFetchQuotaRecordsPerSecondForRegion(String regionName, int kafkaFetchQuotaRecordsPerSecond)

void

setStoreMigrationAllowed(boolean storeMigrationAllowed)

String

toString()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details
- DEFAULT_SERVER_KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND
  
  public static final int DEFAULT_SERVER_KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND
  See Also:
  
  Constant Field Values
Constructor Details
- LiveClusterConfig
  
  public LiveClusterConfig()
- LiveClusterConfig
  
  public LiveClusterConfig(LiveClusterConfig clone)
Method Details
- getServerKafkaFetchQuotaRecordsPerSecond
  
  public Map<String,Integer> getServerKafkaFetchQuotaRecordsPerSecond()
- setServerKafkaFetchQuotaRecordsPerSecond
  
  public void setServerKafkaFetchQuotaRecordsPerSecond(Map<String,Integer> serverKafkaFetchQuotaRecordsPerSecond)
- isStoreMigrationAllowed
  
  public boolean isStoreMigrationAllowed()
- setStoreMigrationAllowed
  
  public void setStoreMigrationAllowed(boolean storeMigrationAllowed)
- isChildControllerAdminTopicConsumptionEnabled
  
  public boolean isChildControllerAdminTopicConsumptionEnabled()
- setChildControllerAdminTopicConsumptionEnabled
  
  public void setChildControllerAdminTopicConsumptionEnabled(boolean childControllerAdminTopicConsumptionEnabled)
- getServerKafkaFetchQuotaRecordsPerSecondForRegion
  
  public int getServerKafkaFetchQuotaRecordsPerSecondForRegion(String regionName)
- setServerKafkaFetchQuotaRecordsPerSecondForRegion
  
  public void setServerKafkaFetchQuotaRecordsPerSecondForRegion(String regionName, int kafkaFetchQuotaRecordsPerSecond)
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object