Package net.bugreaper.modules.kafka.setup

Class KafkaAdminHelper

java.lang.Object
net.bugreaper.modules.kafka.setup.KafkaAdminHelper
public class KafkaAdminHelper extends Object
Kafka admin helper that provides a common API for Kafka administration operations.

  • Constructor Details

    • KafkaAdminHelper

      public KafkaAdminHelper(String bootStrapServer)

  • Method Details

    • createTopicMethod

      public void createTopicMethod(String topic, int partitions)

    • deleteTopicMethod

      public void deleteTopicMethod(String topic)

    • purgeTopicMethod

      public void purgeTopicMethod(String topic)

    • getPartitionsCountMethod

      public int getPartitionsCountMethod(String topic)

    • getTopicExistenceMethod

      public boolean getTopicExistenceMethod(String topic)

    • seeTopicExistsMethod

      public void seeTopicExistsMethod(String topic, int awaitMs)