Class AbstractKafkaClient.Builder<SELF extends AbstractKafkaClient.Builder<SELF>>

    • Constructor Detail

      • Builder

        public Builder()
    • Method Detail

      • withTopicName

        public SELF withTopicName​(String topicName)
      • withPartition

        public SELF withPartition​(Integer partition)
      • withNamespaceName

        public SELF withNamespaceName​(String namespaceName)
      • withClusterName

        public SELF withClusterName​(String clusterName)
      • withMessageCount

        public SELF withMessageCount​(int messageCount)
      • withConsumerGroupName

        public SELF withConsumerGroupName​(String consumerGroup)
      • withKafkaUsername

        public SELF withKafkaUsername​(String kafkaUsername)
      • withSecurityProtocol

        public SELF withSecurityProtocol​(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)
      • withCertificateAuthorityCertificateName

        public SELF withCertificateAuthorityCertificateName​(String caCertName)
      • withListenerName

        public SELF withListenerName​(String listenerName)
      • withSecretPrefix

        public SELF withSecretPrefix​(String secretPrefix)