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 | 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 |
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) |
Modifier and Type | Method and Description |
---|---|
Collection<URL> |
activeNodeUrls(String protocol) |
AbstractAuthCache |
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) |
protected boolean |
existingPartitionRecordsRead(org.apache.kafka.common.TopicPartition topicPartition) |
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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
protected static final org.slf4j.Logger log
protected KafkaStoreConfig clientConfig
protected final org.apache.kafka.common.utils.Time time
protected final int numAuthTopicPartitions
protected final io.confluent.security.auth.dataplane.DataplaneBaseAuthStore.StoreStatusListener statusListener
protected String sessionUuid
protected DataplaneAuthReader<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue> reader
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)
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 cacheprotected boolean existingPartitionRecordsRead(org.apache.kafka.common.TopicPartition topicPartition)