Class ConfluentAuthorizerConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.security.authorizer.ConfluentAuthorizerConfig

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConfluentAuthorizerConfig.Providers

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ACCESS_RULE_PROVIDERS_PROP
static final String	ACL_MIGRATION_BATCH_SIZE_PROP
static final String	ALLOW_IF_NO_ACLS_PROP
final boolean	allowEveryoneIfNoAcl
static final String	BROKER_USERS_PROP
Set<org.apache.kafka.common.security.auth.KafkaPrincipal>	brokerUsers
static final String	ENABLE_INFO_LOGS_FOR_ALLOWED_OPERATION
final boolean	enableAllowAuthorizationInfoLogs
static final String	INIT_TIMEOUT_PROP
final Duration	initTimeout
static final String	MIGRATE_ACLS_FROM_CLUSTER_PROP
static final String	MIGRATE_ACLS_FROM_ZK_PROP
final boolean	migrateAclsFromCluster
static final String	OAUTH_GROUPS_CLAIM_NAME
static final String	SUPER_USERS_PROP
Set<org.apache.kafka.common.security.auth.KafkaPrincipal>	superUsers

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

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOC

Constructor Summary

Constructors

Constructor	Description
ConfluentAuthorizerConfig(Map<?,?> props)

Method Summary

Modifier and Type	Method	Description
static Set<String>	accessRuleProviders(Map<String,?> configs)
List<String>	authProviderNames()
final ConfluentAuthorizerConfig.Providers	createProviders(String clusterId)
final ConfluentAuthorizerConfig.Providers	createProviders(String clusterId, Set<Provider> existing)
static void	main(String[] args)
static Set<org.apache.kafka.common.security.auth.KafkaPrincipal>	parseUsers(String su)
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

ACCESS_RULE_PROVIDERS_PROP

public static final String ACCESS_RULE_PROVIDERS_PROP

See Also:

• Constant Field Values

INIT_TIMEOUT_PROP

public static final String INIT_TIMEOUT_PROP

See Also:

• Constant Field Values

ALLOW_IF_NO_ACLS_PROP

public static final String ALLOW_IF_NO_ACLS_PROP

See Also:

• Constant Field Values

SUPER_USERS_PROP

public static final String SUPER_USERS_PROP

See Also:

• Constant Field Values

BROKER_USERS_PROP

public static final String BROKER_USERS_PROP

See Also:

• Constant Field Values

MIGRATE_ACLS_FROM_ZK_PROP

public static final String MIGRATE_ACLS_FROM_ZK_PROP

See Also:

• Constant Field Values

MIGRATE_ACLS_FROM_CLUSTER_PROP

public static final String MIGRATE_ACLS_FROM_CLUSTER_PROP

See Also:

• Constant Field Values

ACL_MIGRATION_BATCH_SIZE_PROP

public static final String ACL_MIGRATION_BATCH_SIZE_PROP

See Also:

• Constant Field Values

OAUTH_GROUPS_CLAIM_NAME

public static final String OAUTH_GROUPS_CLAIM_NAME

See Also:

• Constant Field Values

ENABLE_INFO_LOGS_FOR_ALLOWED_OPERATION

public static final String ENABLE_INFO_LOGS_FOR_ALLOWED_OPERATION

See Also:

• Constant Field Values

allowEveryoneIfNoAcl

public final boolean allowEveryoneIfNoAcl

migrateAclsFromCluster

public final boolean migrateAclsFromCluster

enableAllowAuthorizationInfoLogs

public final boolean enableAllowAuthorizationInfoLogs

superUsers

public Set<org.apache.kafka.common.security.auth.KafkaPrincipal> superUsers

brokerUsers

public Set<org.apache.kafka.common.security.auth.KafkaPrincipal> brokerUsers

initTimeout

public final Duration initTimeout

Constructor Details

ConfluentAuthorizerConfig

public ConfluentAuthorizerConfig(Map<?,?> props)

Method Details

parseUsers

public static Set<org.apache.kafka.common.security.auth.KafkaPrincipal> parseUsers(String su)

authProviderNames

public List<String> authProviderNames()

createProviders

public final ConfluentAuthorizerConfig.Providers createProviders(String clusterId)

createProviders

public final ConfluentAuthorizerConfig.Providers createProviders(String clusterId,
 Set<Provider> existing)

accessRuleProviders

public static Set<String> accessRuleProviders(Map<String,?> configs)

toString

public String toString()

Overrides:

toString in class Object

main

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

Throws:

Exception