class ConsumerOffsetManager extends ConfigManager {

    public void commitOffset(final String group, final String topic, final int queueId, final long offset) {
        // topic@group
        String key = topic + TOPIC_GROUP_SEPARATOR + group;
        this.commitOffset(key, queueId, offset);
    }

    public  ConsumerOffsetManager();
    public  ConsumerOffsetManager(BrokerController brokerController);

}