io.confluent.security.auth.dataplane

Class DataplaneAuthStore

java.lang.Object

io.confluent.security.auth.dataplane.DataplaneBaseAuthStore

io.confluent.security.auth.dataplane.DataplaneAuthStore

All Implemented Interfaces:

io.confluent.security.auth.metadata.AuthStore, ConsumerListener<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>, Closeable, AutoCloseable, org.apache.kafka.common.Configurable

public class DataplaneAuthStore
extends DataplaneBaseAuthStore

Nested Class Summary

Nested classes/interfaces inherited from class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore

DataplaneBaseAuthStore.DeserializerErrorForKey, DataplaneBaseAuthStore.DeserializerErrorForValue

Field Summary

Fields inherited from interface io.confluent.security.auth.metadata.AuthStore

INSTANCES

Constructor Summary

Constructors

Constructor and Description
DataplaneAuthStore(io.confluent.security.rbac.RbacRoles rbacRoles, org.apache.kafka.common.utils.Time time, io.confluent.security.authorizer.Scope scope, org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo, int numAuthTopicPartitions)
DataplaneAuthStore(io.confluent.security.authorizer.Scope scope, org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(Map<String,?> configs)
static JsonSerde<io.confluent.security.auth.store.data.AuthValue>	valueSerde()

Methods inherited from class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore

activeNodeUrls, authCache, isMasterWriter, keySerde, masterWriterId, masterWriterUrl, onConsumerRecord, startReader, startService, trustCache, writer

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.confluent.security.auth.metadata.AuthStore

addInstance, getInstance, removeInstance

Constructor Detail

DataplaneAuthStore

public DataplaneAuthStore(io.confluent.security.authorizer.Scope scope,
                          org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)

DataplaneAuthStore

public DataplaneAuthStore(io.confluent.security.rbac.RbacRoles rbacRoles,
                          org.apache.kafka.common.utils.Time time,
                          io.confluent.security.authorizer.Scope scope,
                          org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo,
                          int numAuthTopicPartitions)

Method Detail

valueSerde

public static JsonSerde<io.confluent.security.auth.store.data.AuthValue> valueSerde()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class DataplaneBaseAuthStore

configure

public void configure(Map<String,?> configs)