code: public KafkaMessage consumeMessage(String consumerGroupId, boolean consumeFromBeginning,
              String topic, long waitTime, TimeUnit waitTimeUnit) {
          KafkaMsgConsumer kafkaConsumer = getKafkaConsumer(consumerGroupId, consumeFromBeginning);
          return kafkaConsumer.consume(topic, waitTime, waitTimeUnit);
      }
docs: Consumes one message from a topic, wait up to specified wait-time.
  
  <p>
  Note: {@code consumeFromBeginning} is ignored if there is an existing
  consumer for the {@link consumerGroupId}.
  </p>
  
  @param consumerGroupId
  @param consumeFromBeginning
  @param topic
  @param waitTime
  @param waitTimeUnit
  @return