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>
Modifier and Type | Class and Description |
---|---|
static class |
DataplaneBaseAuthStore.DeserializerErrorForKey |
static class |
DataplaneBaseAuthStore.DeserializerErrorForValue |
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() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public static JsonSerde<io.confluent.security.auth.store.data.AuthKey> keySerde()
public static JsonSerde<io.confluent.security.auth.store.data.AuthValue> valueSerde()
public AbstractAuthCache authCache()
authCache
in interface io.confluent.security.auth.metadata.AuthStore
public AbstractAuthCache trustCache()
trustCache
in interface io.confluent.security.auth.metadata.AuthStore
public CompletionStage<Void> startReader()
startReader
in interface io.confluent.security.auth.metadata.AuthStore
public CompletionStage<Void> startService(Collection<URL> nodeUrls)
startService
in interface io.confluent.security.auth.metadata.AuthStore
public io.confluent.security.auth.metadata.AuthWriter writer()
writer
in interface io.confluent.security.auth.metadata.AuthStore
public boolean isMasterWriter()
isMasterWriter
in interface io.confluent.security.auth.metadata.AuthStore
public URL masterWriterUrl(String protocol)
masterWriterUrl
in interface io.confluent.security.auth.metadata.AuthStore
public Integer masterWriterId()
masterWriterId
in interface io.confluent.security.auth.metadata.AuthStore
public Collection<URL> activeNodeUrls(String protocol)
activeNodeUrls
in interface io.confluent.security.auth.metadata.AuthStore
public void close()
close
in interface Closeable
close
in interface AutoCloseable
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)
ConsumerListener
onConsumerRecord
in interface ConsumerListener<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>
record
- the record from consumeroldValue
- old value corresponding to record key from local cache