Package io.confluent.security.auth.ipFiltering

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>

  • Constructor Details

    • IpFilteringAuthStore

      public IpFilteringAuthStore()

  • 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

    • getIpFilteringAuthCache

      public IpFilteringAuthCache getIpFilteringAuthCache()

    • 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

    • findRule

      public io.confluent.security.authorizer.provider.AuthorizeRule findRule()

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • activeNodeUrls

      public Collection<URL> activeNodeUrls(String protocol)
      Specified by:
      activeNodeUrls in interface io.confluent.security.auth.metadata.AuthStore

    • 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

    • configure

      public void configure(Map<String,?> configs)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable