public class ConfluentAuthorizerConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Class and Description |
---|---|
static class |
ConfluentAuthorizerConfig.Providers |
Modifier and Type | Field and Description |
---|---|
static String |
ACCESS_RULE_PROVIDERS_PROP |
static String |
ACL_MIGRATION_BATCH_SIZE_PROP |
static String |
ALLOW_IF_NO_ACLS_PROP |
boolean |
allowEveryoneIfNoAcl |
static String |
BROKER_USERS_PROP |
Set<org.apache.kafka.common.security.auth.KafkaPrincipal> |
brokerUsers |
static String |
INIT_TIMEOUT_PROP |
Duration |
initTimeout |
static String |
MIGRATE_ACLS_FROM_CLUSTER_PROP |
static String |
MIGRATE_ACLS_FROM_ZK_PROP |
boolean |
migrateAclsFromCluster |
static String |
OAUTH_GROUPS_CLAIM_NAME |
static String |
SUPER_USERS_PROP |
Set<org.apache.kafka.common.security.auth.KafkaPrincipal> |
superUsers |
Constructor and Description |
---|
ConfluentAuthorizerConfig(Map<?,?> props) |
Modifier and Type | Method and Description |
---|---|
static Set<String> |
accessRuleProviders(Map<String,?> configs) |
List<String> |
authProviderNames() |
ConfluentAuthorizerConfig.Providers |
createProviders(String clusterId) |
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() |
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 ACCESS_RULE_PROVIDERS_PROP
public static final String INIT_TIMEOUT_PROP
public static final String ALLOW_IF_NO_ACLS_PROP
public static final String SUPER_USERS_PROP
public static final String BROKER_USERS_PROP
public static final String MIGRATE_ACLS_FROM_ZK_PROP
public static final String MIGRATE_ACLS_FROM_CLUSTER_PROP
public static final String ACL_MIGRATION_BATCH_SIZE_PROP
public static final String OAUTH_GROUPS_CLAIM_NAME
public final boolean allowEveryoneIfNoAcl
public final boolean migrateAclsFromCluster
public Set<org.apache.kafka.common.security.auth.KafkaPrincipal> superUsers
public Set<org.apache.kafka.common.security.auth.KafkaPrincipal> brokerUsers
public final Duration initTimeout
public ConfluentAuthorizerConfig(Map<?,?> props)
public static Set<org.apache.kafka.common.security.auth.KafkaPrincipal> parseUsers(String su)
public final ConfluentAuthorizerConfig.Providers createProviders(String clusterId)
public final ConfluentAuthorizerConfig.Providers createProviders(String clusterId, Set<Provider> existing)