public boolean commmit(KafkaMessage msg, String groupId) {
        KafkaMsgConsumer kafkaConsumer = cacheConsumers.get(groupId);
        return kafkaConsumer != null ? kafkaConsumer.commit(msg) : false;
    }
public boolean commmit ( KafkaMessage msg , String groupId ) { KafkaMsgConsumer kafkaConsumer = cacheConsumers . get ( groupId ) ; return kafkaConsumer != null ? kafkaConsumer . commit ( msg ) : false ; }
Commit the specified offsets for the last consumed message.

@param msg
@param groupId
@return {@code true} if the topic is in subscription list, {@code false}
otherwise
@since 1.3.2