Class IpFilteringAuthStore

java.lang.Object

io.confluent.security.auth.ipFiltering.IpFilteringAuthStore

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

Field Summary

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

INSTANCES

Constructor Summary

Constructors

Constructor	Description
IpFilteringAuthStore(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)
IpFilteringAuthStore(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo, org.apache.kafka.common.utils.Time time, int numAuthTopicPartitions)

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)
IpFilteringAuthCache	ipFilteringAuthCache()
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
CompletionStage<Void>	startReader()
CompletionStage<Void>	startService(Collection<URL> serverUrls)
io.confluent.security.trustservice.store.TrustCache	trustCache()
io.confluent.security.auth.metadata.AuthWriter	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

IpFilteringAuthStore

public IpFilteringAuthStore(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)

IpFilteringAuthStore

public IpFilteringAuthStore(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo,
 org.apache.kafka.common.utils.Time time,
 int numAuthTopicPartitions)

Method Details

configure

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

Specified by:

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

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

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

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

ipFilteringAuthCache

public IpFilteringAuthCache ipFilteringAuthCache()

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