public class KafkaStoreConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Field and Description |
---|---|
static String |
ALLOW_READER_TO_CREATE_AUTH_TOPIC |
static String |
BOOTSTRAP_SERVERS_PROP |
int |
brokerId |
static int |
NUM_PARTITIONS |
static String |
PREFIX |
static String |
REFRESH_TIMEOUT_PROP |
Duration |
refreshTimeout |
static String |
REPLICATION_FACTOR_PROP |
static String |
RETRY_TIMEOUT_PROP |
Duration |
retryTimeout |
static String |
TOPIC_CREATE_TIMEOUT_PROP |
static String |
TOPIC_PREFIX |
Duration |
topicCreateTimeout |
Constructor and Description |
---|
KafkaStoreConfig(org.apache.kafka.server.authorizer.AuthorizerServerInfo serverInfo,
Map<?,?> props) |
KafkaStoreConfig(int componentId,
Map<?,?> props) |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
adminClientConfigs() |
Map<String,Object> |
consumerConfigs(String topic) |
Map<String,Object> |
coordinatorConfigs() |
static void |
main(String[] args) |
org.apache.kafka.clients.admin.NewTopic |
metadataTopicCreateConfig(String topic,
int numPartitions) |
int |
minInSyncReplicas() |
Map<String,Object> |
producerConfigs(String topic) |
String |
toString() |
documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final String PREFIX
public static final int NUM_PARTITIONS
public static final String REPLICATION_FACTOR_PROP
public static final String TOPIC_CREATE_TIMEOUT_PROP
public static final String REFRESH_TIMEOUT_PROP
public static final String RETRY_TIMEOUT_PROP
public static final String ALLOW_READER_TO_CREATE_AUTH_TOPIC
public static final String BOOTSTRAP_SERVERS_PROP
public static final String TOPIC_PREFIX
public final Duration topicCreateTimeout
public final Duration refreshTimeout
public final Duration retryTimeout
public final int brokerId
public KafkaStoreConfig(org.apache.kafka.server.authorizer.AuthorizerServerInfo serverInfo, Map<?,?> props)
public KafkaStoreConfig(int componentId, Map<?,?> props)
public org.apache.kafka.clients.admin.NewTopic metadataTopicCreateConfig(String topic, int numPartitions)
public int minInSyncReplicas()