class RemoteBrokerOffsetStore implements OffsetStore {

    @Override
    public void removeOffset(MessageQueue mq) {
        if (mq != null) {
            this.offsetTable.remove(mq);
            log.info("remove unnecessary messageQueue offset. group={}, mq={}, offsetTableSize={}", this.groupName, mq,
                offsetTable.size());
        }
    }

    public  RemoteBrokerOffsetStore(MQClientInstance mQClientFactory, String groupName);

}