Class ClientUtils

    • Method Detail

      • waitTillContinuousClientsFinish

        public static void waitTillContinuousClientsFinish​(String producerName,
                                                           String consumerName,
                                                           String namespace,
                                                           int messageCount)
      • waitForClientSuccess

        public static void waitForClientSuccess​(String jobName,
                                                String namespace,
                                                int messageCount)
      • generateRandomConsumerGroup

        public static String generateRandomConsumerGroup()
        Method which generates random consumer group name
        Returns:
        consumer group name with pattern: my-consumer-group-*-*