public void addSourceReportInfo(String sourceIp,
            String sourcePort, String rptSrcType, String protocolType) {
        sourceReportConfigHolder.addSourceInfo(sourceIp, sourcePort, rptSrcType, protocolType);
    }
get sink topic configure by groupId and streamId
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/ConfigManager.java