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 java.lang.String |
ACCESS_RULE_PROVIDERS_PROP |
static java.lang.String |
ACL_MIGRATION_BATCH_SIZE_PROP |
static java.lang.String |
ALLOW_IF_NO_ACLS_PROP |
boolean |
allowEveryoneIfNoAcl |
static java.lang.String |
BROKER_USERS_PROP |
java.util.Set<org.apache.kafka.common.security.auth.KafkaPrincipal> |
brokerUsers |
static java.lang.String |
INIT_TIMEOUT_PROP |
java.time.Duration |
initTimeout |
static java.lang.String |
MIGRATE_ACLS_FROM_ZK_PROP |
boolean |
migrateAclsFromZK |
static java.lang.String |
SUPER_USERS_PROP |
java.util.Set<org.apache.kafka.common.security.auth.KafkaPrincipal> |
superUsers |
Constructor and Description |
---|
ConfluentAuthorizerConfig(java.util.Map<?,?> props) |
Modifier and Type | Method and Description |
---|---|
static java.util.Set<java.lang.String> |
accessRuleProviders(java.util.Map<java.lang.String,?> configs) |
ConfluentAuthorizerConfig.Providers |
createProviders(java.lang.String clusterId,
org.apache.kafka.server.audit.AuditLogProvider auditLogProvider) |
static void |
main(java.lang.String[] args) |
static java.util.Set<org.apache.kafka.common.security.auth.KafkaPrincipal> |
parseUsers(java.lang.String su) |
java.lang.String |
toString() |
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final java.lang.String ACCESS_RULE_PROVIDERS_PROP
public static final java.lang.String INIT_TIMEOUT_PROP
public static final java.lang.String ALLOW_IF_NO_ACLS_PROP
public static final java.lang.String SUPER_USERS_PROP
public static final java.lang.String BROKER_USERS_PROP
public static final java.lang.String MIGRATE_ACLS_FROM_ZK_PROP
public static final java.lang.String ACL_MIGRATION_BATCH_SIZE_PROP
public final boolean allowEveryoneIfNoAcl
public final boolean migrateAclsFromZK
public java.util.Set<org.apache.kafka.common.security.auth.KafkaPrincipal> superUsers
public java.util.Set<org.apache.kafka.common.security.auth.KafkaPrincipal> brokerUsers
public final java.time.Duration initTimeout
public ConfluentAuthorizerConfig(java.util.Map<?,?> props)
public static java.util.Set<org.apache.kafka.common.security.auth.KafkaPrincipal> parseUsers(java.lang.String su)
public final ConfluentAuthorizerConfig.Providers createProviders(java.lang.String clusterId, org.apache.kafka.server.audit.AuditLogProvider auditLogProvider)
public static java.util.Set<java.lang.String> accessRuleProviders(java.util.Map<java.lang.String,?> configs)
public java.lang.String toString()
toString
in class java.lang.Object
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception