Package 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	Description
DataplaneAuthStore(io.confluent.security.authorizer.Scope scope, org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)
DataplaneAuthStore(io.confluent.security.roledefinitions.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 Summary

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

Constructor Details

DataplaneAuthStore

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

DataplaneAuthStore

public DataplaneAuthStore(io.confluent.security.roledefinitions.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 Details

valueSerde

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

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class DataplaneBaseAuthStore

configure

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