Package net.bugreaper.modules.kafka.setup

Class KafkaConsumerHelper

java.lang.Object
net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
Direct Known Subclasses:
Kafka
public class KafkaConsumerHelper extends Object
Kafka consumer helper responsible for consuming messages from Kafka topics.

  • Field Details

    • bootStrapServer

      protected final String bootStrapServer

    • adminClient

      protected final KafkaAdminHelper adminClient

    • awaitMs

      protected volatile int awaitMs
      default ms await in tests

    • consumerTimeoutMs

      protected volatile int consumerTimeoutMs
      default max ms for consumer

    • maxConsumedMessages

      protected volatile int maxConsumedMessages
      default max messages that will be consumed by grab

    • uniqueConsumerGroup

      protected volatile boolean uniqueConsumerGroup
      switch for unique groupId for consumer

    • reverseMessages

      protected volatile boolean reverseMessages
      default consumed messages will be reversed in list (newer messages will be checked first)

  • Constructor Details

    • KafkaConsumerHelper

      protected KafkaConsumerHelper(String bootStrapServer)

  • Method Details

    • consumer

      protected org.apache.kafka.clients.consumer.KafkaConsumer<String,String> consumer()

    • grabMessagesFromTopicMethod

      protected net.bugreaper.core.assertable.AssertableStringList grabMessagesFromTopicMethod(String topic, String key)

    • getAllTopicsNamesMethod

      protected net.bugreaper.core.assertable.AssertableStringList getAllTopicsNamesMethod()

    • getTopicMessageCountMethod

      protected int getTopicMessageCountMethod(String topic)

    • assertCountInTopicMethod

      protected void assertCountInTopicMethod(String topic, int expectedCount, int awaitMs)

    • seeTopicIsNotEmptyMethod

      protected void seeTopicIsNotEmptyMethod(String topic, int awaitMs)

    • seeTopicIsEmptyMethod

      protected void seeTopicIsEmptyMethod(String topic, int awaitMs)