public class DataplaneAuthStore extends DataplaneBaseAuthStore
DataplaneBaseAuthStore.DeserializerErrorForKey, DataplaneBaseAuthStore.DeserializerErrorForValue
Constructor and Description |
---|
DataplaneAuthStore(io.confluent.security.rbac.RbacRoles rbacRoles,
org.apache.kafka.common.utils.Time time,
io.confluent.security.authorizer.Scope scope,
org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo,
int numAuthTopicPartitions) |
DataplaneAuthStore(io.confluent.security.authorizer.Scope scope,
org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
static JsonSerde<io.confluent.security.auth.store.data.AuthValue> |
valueSerde() |
activeNodeUrls, authCache, close, isMasterWriter, keySerde, masterWriterId, masterWriterUrl, onConsumerRecord, startReader, startService, trustCache, writer
public DataplaneAuthStore(io.confluent.security.authorizer.Scope scope, org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)
public DataplaneAuthStore(io.confluent.security.rbac.RbacRoles rbacRoles, org.apache.kafka.common.utils.Time time, io.confluent.security.authorizer.Scope scope, org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo, int numAuthTopicPartitions)