Class AbstractKafkaClientProperties.KafkaClientPropertiesBuilder<T extends AbstractKafkaClientProperties.KafkaClientPropertiesBuilder<T>>

    • Constructor Detail

      • KafkaClientPropertiesBuilder

        public KafkaClientPropertiesBuilder()
    • Method Detail

      • withNamespaceName

        public T withNamespaceName​(String namespaceName)
      • withClusterName

        public T withClusterName​(String clusterName)
      • withCaSecretName

        public T withCaSecretName​(String caSecretName)
      • withKafkaUsername

        public T withKafkaUsername​(String kafkaUsername)
      • withSecurityProtocol

        public T withSecurityProtocol​(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)
      • withSaslMechanism

        public T withSaslMechanism​(String saslMechanismType)
      • withSaslLoginCallbackHandlerClass

        public T withSaslLoginCallbackHandlerClass()
      • withSaslJassConfig

        public T withSaslJassConfig​(String clientId,
                                    String clientSecretName,
                                    String oauthTokenEndpointUri)
      • withSaslJassConfigAndTls

        public T withSaslJassConfigAndTls​(String clientId,
                                          String clientSecretName,
                                          String oauthTokenEndpointUri)
      • withSharedProperties

        public T withSharedProperties()
        Create properties which are same pro producer and consumer