Class KafkaCmdClient


  • public class KafkaCmdClient
    extends Object
    • Constructor Detail

      • KafkaCmdClient

        public KafkaCmdClient()
    • Method Detail

      • listTopicsUsingPodCli

        public static List<String> listTopicsUsingPodCli​(String clusterName,
                                                         int kafkaPodId)
      • createTopicUsingPodCli

        public static String createTopicUsingPodCli​(String clusterName,
                                                    int kafkaPodId,
                                                    String topic,
                                                    int replicationFactor,
                                                    int partitions)
      • deleteTopicUsingPodCli

        public static String deleteTopicUsingPodCli​(String clusterName,
                                                    int kafkaPodId,
                                                    String topic)
      • describeTopicUsingPodCli

        public static List<String> describeTopicUsingPodCli​(String clusterName,
                                                            int kafkaPodId,
                                                            String topic)
      • updateTopicPartitionsCountUsingPodCli

        public static String updateTopicPartitionsCountUsingPodCli​(String clusterName,
                                                                   int kafkaPodId,
                                                                   String topic,
                                                                   int partitions)