@Override
    public ConcurrentHashMap<String, OffsetStorageInfo> loadGroupStgInfo(String group) {
        return new ConcurrentHashMap<>();
    }
Initial ZooKeeper offset storage object

@param zkConfig   the ZooKeeper configure
@param isBroker   whether used in broker node
@param brokerId   the broker id
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/offsetstorage/ZkOffsetStorage.java