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 inherited from interface io.confluent.security.auth.metadata.AuthStore

INSTANCES

Method Summary

Modifier and Type	Method and Description
Collection<URL>	activeNodeUrls(String protocol)
AbstractAuthCache	authCache()
void	close()
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)
AbstractAuthCache	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

equals, 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

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 AbstractAuthCache authCache()

Specified by:

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

trustCache

public AbstractAuthCache 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