Class ExternalKafkaAuthStore

java.lang.Object

io.confluent.security.auth.store.kafka.ExternalKafkaAuthStore

All Implemented Interfaces:

io.confluent.security.auth.metadata.AuthStore, Closeable, AutoCloseable, org.apache.kafka.common.Configurable

public class ExternalKafkaAuthStore
extends Object
implements io.confluent.security.auth.metadata.AuthStore

Field Summary

Fields

Modifier and Type	Field	Description
static final String	METRIC_GROUP

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

INSTANCES

Constructor Summary

Constructors

Constructor	Description
ExternalKafkaAuthStore(io.confluent.security.authorizer.Scope scope, org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)
ExternalKafkaAuthStore(io.confluent.security.authorizer.Scope scope, org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo, io.confluent.security.roledefinitions.RbacRoles rbacRoles)

Method Summary

Modifier and Type	Method	Description
Collection<URL>	activeNodeUrls(String protocol)
io.confluent.security.auth.metadata.AuthCache	authCache()
void	close()
void	configure(Map<String,?> configs)
boolean	isMasterWriter()
Integer	masterWriterId()
URL	masterWriterUrl(String protocol)
CompletionStage<Void>	startReader()
CompletionStage<Void>	startService(Collection<URL> serverUrls)
io.confluent.security.trustservice.store.TrustCache	trustCache()
void	updateStoreAuthCacheExternally(byte[] key, byte[] value)
io.confluent.security.auth.metadata.AuthWriter	writer()

Methods inherited from class java.lang.Object

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

Field Details

METRIC_GROUP

public static final String METRIC_GROUP

See Also:

• Constant Field Values

Constructor Details

ExternalKafkaAuthStore

public ExternalKafkaAuthStore(io.confluent.security.authorizer.Scope scope,
 org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)

ExternalKafkaAuthStore

public ExternalKafkaAuthStore(io.confluent.security.authorizer.Scope scope,
 org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo,
 io.confluent.security.roledefinitions.RbacRoles rbacRoles)

Method Details

startReader

public CompletionStage<Void> startReader()

Specified by:

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

startService

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

Specified by:

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

authCache

public io.confluent.security.auth.metadata.AuthCache authCache()

Specified by:

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

trustCache

public io.confluent.security.trustservice.store.TrustCache trustCache()

Specified by:

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

writer

public io.confluent.security.auth.metadata.AuthWriter writer()

Specified by:

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

isMasterWriter

public 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()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

configure

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

Specified by:

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

updateStoreAuthCacheExternally

public void updateStoreAuthCacheExternally(byte[] key,
 byte[] value)

Specified by:

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