Class KafkaStoreConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.security.store.kafka.KafkaStoreConfig

public class KafkaStoreConfig
extends org.apache.kafka.common.config.AbstractConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ALLOW_READER_TO_CREATE_AUTH_TOPIC
static final String	BOOTSTRAP_SERVERS_PROP
final int	brokerId
static final int	NUM_PARTITIONS
static final String	PREFIX
static final String	REFRESH_TIMEOUT_PROP
final Duration	refreshTimeout
static final String	REPLICATION_FACTOR_PROP
static final String	RETRY_TIMEOUT_PROP
final Duration	retryTimeout
static final String	TOPIC_CREATE_TIMEOUT_PROP
static final String	TOPIC_PREFIX
final Duration	topicCreateTimeout

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
KafkaStoreConfig(int componentId, Map<?,?> props)
KafkaStoreConfig(org.apache.kafka.server.authorizer.AuthorizerServerInfo serverInfo, Map<?,?> props)

Method Summary

Modifier and Type	Method	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()

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

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

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Details

PREFIX

public static final String PREFIX

See Also:

• Constant Field Values

NUM_PARTITIONS

public static final int NUM_PARTITIONS

See Also:

• Constant Field Values

REPLICATION_FACTOR_PROP

public static final String REPLICATION_FACTOR_PROP

See Also:

• Constant Field Values

TOPIC_CREATE_TIMEOUT_PROP

public static final String TOPIC_CREATE_TIMEOUT_PROP

See Also:

• Constant Field Values

REFRESH_TIMEOUT_PROP

public static final String REFRESH_TIMEOUT_PROP

See Also:

• Constant Field Values

RETRY_TIMEOUT_PROP

public static final String RETRY_TIMEOUT_PROP

See Also:

• Constant Field Values

ALLOW_READER_TO_CREATE_AUTH_TOPIC

public static final String ALLOW_READER_TO_CREATE_AUTH_TOPIC

See Also:

• Constant Field Values

BOOTSTRAP_SERVERS_PROP

public static final String BOOTSTRAP_SERVERS_PROP

See Also:

• Constant Field Values

TOPIC_PREFIX

public static final String TOPIC_PREFIX

See Also:

• Constant Field Values

topicCreateTimeout

public final Duration topicCreateTimeout

refreshTimeout

public final Duration refreshTimeout

retryTimeout

public final Duration retryTimeout

brokerId

public final int brokerId

Constructor Details

KafkaStoreConfig

public KafkaStoreConfig(org.apache.kafka.server.authorizer.AuthorizerServerInfo serverInfo,
 Map<?,?> props)

KafkaStoreConfig

public KafkaStoreConfig(int componentId,
 Map<?,?> props)

Method Details

consumerConfigs

public Map<String,Object> consumerConfigs(String topic)

producerConfigs

public Map<String,Object> producerConfigs(String topic)

coordinatorConfigs

public Map<String,Object> coordinatorConfigs()

adminClientConfigs

public Map<String,Object> adminClientConfigs()

metadataTopicCreateConfig

public org.apache.kafka.clients.admin.NewTopic metadataTopicCreateConfig(String topic,
 int numPartitions)

minInSyncReplicas

public int minInSyncReplicas()

toString

public String toString()

Overrides:

toString in class Object

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception