Class AbstractKafkaClient<C extends AbstractKafkaClient.Builder<C>>

    • Method Detail

      • setMessageCount

        public void setMessageCount​(int messageCount)
      • verifyProducedAndConsumedMessages

        public void verifyProducedAndConsumedMessages​(int producedMessages,
                                                      int consumedMessages)
      • getBootstrapServerFromStatus

        public String getBootstrapServerFromStatus()
      • getTopicName

        public String getTopicName()
      • getPartition

        public Integer getPartition()
      • getMessageCount

        public int getMessageCount()
      • getConsumerGroup

        public String getConsumerGroup()
      • getKafkaUsername

        public String getKafkaUsername()
      • getSecurityProtocol

        public org.apache.kafka.common.security.auth.SecurityProtocol getSecurityProtocol()
      • getCaCertName

        public String getCaCertName()
      • getListenerName

        public String getListenerName()
      • getSecretPrefix

        public String getSecretPrefix()