code: public boolean commitAsync(String topic, String groupId) {
          KafkaMsgConsumer kafkaConsumer = cacheConsumers.get(groupId);
          return kafkaConsumer != null ? kafkaConsumer.commitAsync(topic) : false;
      }
docs: Commit offsets returned on the last poll for all the subscribed
  partitions.
  
  @param topic
  @param groupId
  @return
  @since 1.3.2