Class KafkaBasicExampleClients

    • Method Detail

      • getProducerName

        public String getProducerName()
      • getConsumerName

        public String getConsumerName()
      • getBootstrapAddress

        public String getBootstrapAddress()
      • getTopicName

        public String getTopicName()
      • getMessageCount

        public int getMessageCount()
      • getAdditionalConfig

        public String getAdditionalConfig()
      • getConsumerGroup

        public String getConsumerGroup()
      • getDelayMs

        public long getDelayMs()
      • producerStrimzi

        public io.fabric8.kubernetes.api.model.batch.JobBuilder producerStrimzi()
      • consumerStrimzi

        public io.fabric8.kubernetes.api.model.batch.JobBuilder consumerStrimzi()
      • defaultProducerStrimzi

        public io.fabric8.kubernetes.api.model.batch.JobBuilder defaultProducerStrimzi()
      • defaultConsumerStrimzi

        public io.fabric8.kubernetes.api.model.batch.JobBuilder defaultConsumerStrimzi()
      • createAndWaitForReadiness

        public io.fabric8.kubernetes.api.model.batch.Job createAndWaitForReadiness​(io.fabric8.kubernetes.api.model.batch.Job job)