@Override
        void run(String arg, boolean isTimeout) {
            String[] nodeStrs = arg.split(TokenConstants.GROUP_SEP);
            String consumerId = nodeStrs[0];
            String group = nodeStrs[1];
            Integer lid = null;
            try {
                lid = masterRowLock.getLock(null,
                        StringUtils.getBytesUtf8(consumerId), true);
                ConsumerInfo info = consumerHolder.removeConsumer(group, consumerId, isTimeout);
                currentSubInfo.remove(consumerId);
                consumerEventManager.removeAll(consumerId);
                if (info != null) {
                    if (consumerHolder.isConsumeGroupEmpty(group)) {
                        topicPSInfoManager.rmvGroupSubTopicInfo(group, info.getTopicSet());
                    }
                }
            } catch (IOException e) {
                logger.warn("Failed to lock.", e);
            } finally {
                if (lid != null) {
                    masterRowLock.releaseRowLock(lid);
                }
            }
        }
check bdb meta-data path, create it if not exist

@throws Exception
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/TMaster.java