Class AuthnzAuthStore

java.lang.Object

io.confluent.security.auth.dataplane.DataplaneBaseAuthStore

io.confluent.security.auth.dataplane.AuthnzAuthStore

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 AuthnzAuthStore
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
AuthnzAuthStore(io.confluent.security.authorizer.Scope scope, org.apache.kafka.common.metrics.Metrics metrics)
AuthnzAuthStore(io.confluent.security.roledefinitions.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	Description
void	configure(Map<String,?> configs)

Methods inherited from class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore

activeNodeUrls, authCache, close, isMasterWriter, keySerde, masterWriterId, masterWriterUrl, onConsumerRecord, startReader, startService, trustCache, valueSerde, 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

updateStoreAuthCacheExternally

Constructor Details

AuthnzAuthStore

public AuthnzAuthStore(io.confluent.security.authorizer.Scope scope,
 org.apache.kafka.common.metrics.Metrics metrics)

AuthnzAuthStore

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

configure

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