public class AuthnzAuthStore extends DataplaneBaseAuthStore
DataplaneBaseAuthStore.DeserializerErrorForKey, DataplaneBaseAuthStore.DeserializerErrorForValue
clientConfig, log, numAuthTopicPartitions, reader, sessionUuid, statusListener, time
Constructor and Description |
---|
AuthnzAuthStore(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) |
AuthnzAuthStore(io.confluent.security.authorizer.Scope scope,
org.apache.kafka.common.metrics.Metrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
activeNodeUrls, authCache, close, createConsumer, existingPartitionRecordsRead, isMasterWriter, keySerde, masterWriterId, masterWriterUrl, onConsumerRecord, startReader, startService, trustCache, valueSerde, writer
public AuthnzAuthStore(io.confluent.security.authorizer.Scope scope, org.apache.kafka.common.metrics.Metrics metrics)
public AuthnzAuthStore(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)