Class EmbeddedKafkaModule

java.lang.Object
org.glassfish.hk2.utilities.binding.AbstractBinder
io.confluent.kafkarest.extension.EmbeddedKafkaModule
All Implemented Interfaces:
org.glassfish.hk2.api.DynamicConfiguration, org.glassfish.hk2.utilities.Binder
public final class EmbeddedKafkaModule extends org.glassfish.hk2.utilities.binding.AbstractBinder
A binder module that provides instances injected from Kafka via KafkaHttpServerInjector. Only applicable when Kafka REST is embedded in the Kafka process and runs in the Kafka HTTP server.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    final io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
    secretsStore
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    EmbeddedKafkaModule(io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore secretsStore)
     

  • Method Summary

    Methods inherited from class org.glassfish.hk2.utilities.binding.AbstractBinder

    addActiveDescriptor, addActiveDescriptor, addActiveDescriptor, addActiveFactoryDescriptor, addIdempotentFilter, addUnbindFilter, bind, bind, bind, bind, bind, bind, bind, bindAsContract, bindAsContract, bindAsContract, bindFactory, bindFactory, bindFactory, commit, install, registerTwoPhaseResources

    Methods inherited from class java.lang.Object

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

  • Field Details

    • secretsStore

      public final io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore secretsStore

  • Constructor Details

    • EmbeddedKafkaModule

      public EmbeddedKafkaModule(@Nullable io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore secretsStore)
      Parameters:
      secretsStore - A topic-based credentials store for API keys in Confluent Cloud. Can be null in Confluent Platform environments and potentially some Confluent Cloud environments.