@Override
                public void run() {
                    Set<String> removedTopics = storeManager.removeTopicStore();
                    offsetManager.cleanRmvTopicInfo(removedTopics);
                }
Start broker service.

@throws Exception  the exception during processing
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/TubeBroker.java