Class DefaultMTlsConnectionManager

java.lang.Object
io.confluent.security.mtls.DefaultMTlsConnectionManager
All Implemented Interfaces:
org.apache.kafka.common.Configurable, org.apache.kafka.common.security.mtls.MTlsConnectionManager
public class DefaultMTlsConnectionManager extends Object implements org.apache.kafka.common.security.mtls.MTlsConnectionManager
The default implementation of MTlsConnectionManager that relies on the broker session.

  • Constructor Details

    • DefaultMTlsConnectionManager

      public DefaultMTlsConnectionManager()

  • Method Details

    • configure

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

    • closeConnections

      public void closeConnections(org.apache.kafka.common.network.PublicCredential credential)
      Specified by:
      closeConnections in interface org.apache.kafka.common.security.mtls.MTlsConnectionManager