@Override
    public TubeMQResult queryGroupExist(QueryConsumerGroupReq req) {
        MasterEntry masterNode = masterService.getMasterNode(req);
        TubeHttpGroupDetailInfo groupDetailInfo = requestGroupRunInfo(masterNode,
                req.getConsumerGroup());
        List<String> topicSet = groupDetailInfo.getTopicSet();
        if (topicSet.stream().anyMatch(topic -> topic.equals(req.getTopicName()))) {
            return TubeMQResult.successResult();
        }
        return TubeMQResult.errorResult(TubeMQErrorConst.NO_SUCH_GROUP);
    }
node service to query broker/master/standby status of tube cluster.
inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/service/TopicServiceImpl.java