Class KafkaSecurity

java.lang.Object
org.mockserver.async.security.KafkaSecurity

public final class KafkaSecurity extends Object
Immutable carrier for Kafka security configuration (SASL and/or SSL). All fields are optional; when all are null or blank, isEmpty() returns true and no security properties are applied to the Kafka client.
  • Method Details

    • getSecurityProtocol

      public String getSecurityProtocol()
    • getSaslMechanism

      public String getSaslMechanism()
    • getSaslJaasConfig

      public String getSaslJaasConfig()
    • getSslTruststoreLocation

      public String getSslTruststoreLocation()
    • getSslTruststorePassword

      public String getSslTruststorePassword()
    • getSslKeystoreLocation

      public String getSslKeystoreLocation()
    • getSslKeystorePassword

      public String getSslKeystorePassword()
    • getSslKeyPassword

      public String getSslKeyPassword()
    • isEmpty

      public boolean isEmpty()
      Returns true when no security fields are set (all null or blank).
    • empty

      public static KafkaSecurity empty()
      Returns a new empty (no-op) security instance.
    • builder

      public static KafkaSecurity.Builder builder()