Package io.confluent.security.auth.store.kafka

Class KafkaAuthStore

java.lang.Object

io.confluent.security.auth.store.kafka.KafkaAuthStore

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 KafkaAuthStore
extends Object
implements io.confluent.security.auth.metadata.AuthStore, ConsumerListener<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaAuthStore.BackOffDecorator<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AUTH_TOPIC
static final String	METRIC_GROUP

Fields inherited from interface io.confluent.security.auth.metadata.AuthStore

INSTANCES

Constructor Summary

Constructors

Constructor	Description
KafkaAuthStore(boolean isConfluentCloud, io.confluent.security.authorizer.Scope scope, org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo, boolean isMdsApiEnabledOnThisBroker)
KafkaAuthStore(io.confluent.security.roledefinitions.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, boolean isMdsApiEnabledOnThisBroker)

Method Summary

Modifier and Type	Method	Description
Collection<URL>	activeNodeUrls(String protocol)
AbstractAuthCache	authCache()
void	close()
void	close(Duration closeTimeout)
void	configure(Map<String,?> configs)
final boolean	isMasterWriter()
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
static boolean	retryPredicate(Exception e)
CompletionStage<Void>	startReader()
CompletionStage<Void>	startService(Collection<URL> nodeUrls)
AbstractAuthCache	trustCache()
KafkaAuthWriter	writer()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

AUTH_TOPIC

public static final String AUTH_TOPIC

See Also:

• Constant Field Values

METRIC_GROUP

public static final String METRIC_GROUP

See Also:

• Constant Field Values

Constructor Details

KafkaAuthStore

public KafkaAuthStore(boolean isConfluentCloud,
 io.confluent.security.authorizer.Scope scope,
 org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo,
 boolean isMdsApiEnabledOnThisBroker)

KafkaAuthStore

public KafkaAuthStore(io.confluent.security.roledefinitions.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,
 boolean isMdsApiEnabledOnThisBroker)

Method Details

retryPredicate

public static boolean retryPredicate(Exception e)

configure

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

Specified by:

configure in interface org.apache.kafka.common.Configurable

authCache

public AbstractAuthCache authCache()

Specified by:

authCache in interface io.confluent.security.auth.metadata.AuthStore

trustCache

public AbstractAuthCache trustCache()

Specified by:

trustCache in interface io.confluent.security.auth.metadata.AuthStore

startReader

public CompletionStage<Void> startReader()

Specified by:

startReader in interface io.confluent.security.auth.metadata.AuthStore

startService

public CompletionStage<Void> startService(Collection<URL> nodeUrls)

Specified by:

startService in interface io.confluent.security.auth.metadata.AuthStore

writer

public KafkaAuthWriter writer()

Specified by:

writer in interface io.confluent.security.auth.metadata.AuthStore

isMasterWriter

public final boolean isMasterWriter()

Specified by:

isMasterWriter in interface io.confluent.security.auth.metadata.AuthStore

masterWriterUrl

public URL masterWriterUrl(String protocol)

Specified by:

masterWriterUrl in interface io.confluent.security.auth.metadata.AuthStore

masterWriterId

public Integer masterWriterId()

Specified by:

masterWriterId in interface io.confluent.security.auth.metadata.AuthStore

activeNodeUrls

public Collection<URL> activeNodeUrls(String protocol)

Specified by:

activeNodeUrls in interface io.confluent.security.auth.metadata.AuthStore

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

close

public void close(Duration closeTimeout)

onConsumerRecord

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)

Description copied from interface: ConsumerListener

Notification of new record consumed by local reader

Specified by:

onConsumerRecord in interface ConsumerListener<io.confluent.security.auth.store.data.AuthKey,io.confluent.security.auth.store.data.AuthValue>

Parameters:

record - the record from consumer

oldValue - old value corresponding to record key from local cache