public class RestoreConfig extends Object
Modifier and Type | Field and Description |
---|---|
static String |
BUCKET_NAME |
static String |
CLOUD_PROVIDER |
static String |
CLUSTER_ID_CONFIG |
static boolean |
dryRun |
static String |
KAFKA_BOOTSTRAP_PORT_CONFIG |
static String |
KAFKA_INTERNAL_REST_SERVER_PORT_CONFIG |
static int |
kafkaBootstrapPort |
static int |
kafkaInternalRestServerPort |
static boolean |
localMode |
static int |
MAX_KAFKA_CONNECTION_POOL_SIZE |
static int |
OBJECT_STORE_POOL_SIZE_MULTIPLIER |
static String |
PARTITION_FILE_CONFIG |
static String |
RESTORE_PARALLELISM |
static int |
RESTORE_REST_SERVER_PORT |
static String |
ZOOKEEPER_CONFIG |
Modifier and Type | Method and Description |
---|---|
static RestoreConfig |
getInstance() |
Properties |
getProperties() |
static String |
getProperty(String name) |
static kafka.server.KafkaConfig |
kafkaConfig() |
void |
loadAdditionalProps(Properties props) |
static void |
setDryRun(boolean dryRun) |
static void |
setKafkaBootstrapPort(int port) |
static void |
setKafkaInternalRestPort(int port) |
static void |
setLocalMode(boolean localMode) |
static void |
setProperty(String key,
String value) |
public static boolean dryRun
public static boolean localMode
public static final String BUCKET_NAME
public static final String CLOUD_PROVIDER
public static final String PARTITION_FILE_CONFIG
public static final String ZOOKEEPER_CONFIG
public static final String CLUSTER_ID_CONFIG
public static final int RESTORE_REST_SERVER_PORT
public static final String KAFKA_INTERNAL_REST_SERVER_PORT_CONFIG
public static int kafkaInternalRestServerPort
public static final String KAFKA_BOOTSTRAP_PORT_CONFIG
public static int kafkaBootstrapPort
public static final String RESTORE_PARALLELISM
public static final int MAX_KAFKA_CONNECTION_POOL_SIZE
public static final int OBJECT_STORE_POOL_SIZE_MULTIPLIER
public static RestoreConfig getInstance()
public static kafka.server.KafkaConfig kafkaConfig()
public void loadAdditionalProps(Properties props)
public Properties getProperties()
public static void setDryRun(boolean dryRun)
public static void setLocalMode(boolean localMode)
public static void setKafkaInternalRestPort(int port)
public static void setKafkaBootstrapPort(int port)