code: public boolean addMessageListener(String consumerGroupId, boolean consumeFromBeginning,
              String topic, IKafkaMessageListener messageListener) {
          KafkaMsgConsumer kafkaConsumer = getKafkaConsumer(consumerGroupId, consumeFromBeginning);
          return kafkaConsumer.addMessageListener(topic, messageListener);
      }
docs: Adds a message listener for a topic.
  
  <p>
  Note: {@code consumeFromBeginning} is ignored if there is an existing
  consumer for the {@link consumerGroupId}.
  </p>
  
  @param consumerGroupId
  @param consumeFromBeginning
  @param topic
  @param messageListener
  @return {@code true} if successful, {@code false} otherwise (the listener
  may have been added already)