io.confluent.security.auth.dataplane

Class DataplaneBaseAuthStore

java.lang.Object

io.confluent.security.auth.dataplane.DataplaneBaseAuthStore

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

Direct Known Subclasses:

AuthnzAuthStore, DataplaneAuthStore

public abstract class DataplaneBaseAuthStore
extends Object
implements io.confluent.security.auth.metadata.AuthStore, ConsumerListener<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DataplaneBaseAuthStore.DeserializerErrorForKey
static class	DataplaneBaseAuthStore.DeserializerErrorForValue

Field Summary

Fields

Modifier and Type	Field and Description
protected KafkaStoreConfig	clientConfig
protected static org.slf4j.Logger	log
protected int	numAuthTopicPartitions
protected DataplaneAuthReader<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>	reader
protected String	sessionUuid
protected io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.StoreStatusListener	statusListener
protected org.apache.kafka.common.utils.Time	time

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

INSTANCES

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DataplaneBaseAuthStore(io.confluent.security.rbac.RbacRoles rbacRoles, org.apache.kafka.common.utils.Time time, io.confluent.security.authorizer.Scope scope, org.apache.kafka.common.metrics.Metrics metrics, int numAuthTopicPartitions)

Method Summary

Modifier and Type	Method and Description
Collection<URL>	activeNodeUrls(String protocol)
DefaultAuthCache	authCache()
void	close()
protected org.apache.kafka.clients.consumer.Consumer<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>	createConsumer(Map<String,Object> configs)
boolean	isMasterWriter()
static JsonSerde<io.confluent.security.auth.store.data.AuthKey>	keySerde()
Integer	masterWriterId()
URL	masterWriterUrl(String protocol)
void	onConsumerRecord(org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue> record, io.confluent.security.auth.store.data.AuthValue oldValue) Notification of new record consumed by local reader
CompletionStage<Void>	startReader()
CompletionStage<Void>	startService(Collection<URL> nodeUrls)
DefaultAuthCache	trustCache()
static JsonSerde<io.confluent.security.auth.store.data.AuthValue>	valueSerde()
io.confluent.security.auth.metadata.AuthWriter	writer()

Methods inherited from class java.lang.Object

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

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

addInstance, getInstance, removeInstance

Methods inherited from interface org.apache.kafka.common.Configurable

configure

Field Detail

log

protected static final org.slf4j.Logger log

clientConfig

protected KafkaStoreConfig clientConfig

time

protected final org.apache.kafka.common.utils.Time time

numAuthTopicPartitions

protected final int numAuthTopicPartitions

statusListener

protected final io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.StoreStatusListener statusListener

sessionUuid

protected String sessionUuid

reader

protected DataplaneAuthReader<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue> reader

Constructor Detail

DataplaneBaseAuthStore

protected DataplaneBaseAuthStore(io.confluent.security.rbac.RbacRoles rbacRoles,
                                 org.apache.kafka.common.utils.Time time,
                                 io.confluent.security.authorizer.Scope scope,
                                 org.apache.kafka.common.metrics.Metrics metrics,
                                 int numAuthTopicPartitions)

Method Detail

keySerde

public static JsonSerde<io.confluent.security.auth.store.data.AuthKey> keySerde()

valueSerde

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

authCache

public DefaultAuthCache authCache()

Specified by:

authCache in interface io.confluent.security.auth.metadata.AuthStore

trustCache

public DefaultAuthCache trustCache()

Specified by:

trustCache in interface io.confluent.security.auth.metadata.AuthStore

startReader

public CompletionStage<Void> startReader()

Specified by:

startReader in interface io.confluent.security.auth.metadata.AuthStore

startService

public CompletionStage<Void> startService(Collection<URL> nodeUrls)

Specified by:

startService in interface io.confluent.security.auth.metadata.AuthStore

writer

public io.confluent.security.auth.metadata.AuthWriter writer()

Specified by:

writer in interface io.confluent.security.auth.metadata.AuthStore

isMasterWriter

public boolean isMasterWriter()

Specified by:

isMasterWriter in interface io.confluent.security.auth.metadata.AuthStore

masterWriterUrl

public URL masterWriterUrl(String protocol)

Specified by:

masterWriterUrl in interface io.confluent.security.auth.metadata.AuthStore

masterWriterId

public Integer masterWriterId()

Specified by:

masterWriterId in interface io.confluent.security.auth.metadata.AuthStore

activeNodeUrls

public Collection<URL> activeNodeUrls(String protocol)

Specified by:

activeNodeUrls in interface io.confluent.security.auth.metadata.AuthStore

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

onConsumerRecord

public void onConsumerRecord(org.apache.kafka.clients.consumer.ConsumerRecord<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue> record,
                             io.confluent.security.auth.store.data.AuthValue oldValue)

Description copied from interface: ConsumerListener

Notification of new record consumed by local reader

Specified by:

onConsumerRecord in interface ConsumerListener<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

Parameters:

record - the record from consumer

oldValue - old value corresponding to record key from local cache

createConsumer

protected org.apache.kafka.clients.consumer.Consumer<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue> createConsumer(Map<String,Object> configs)