pocozh commented on a change in pull request #2767:
URL: https://github.com/apache/incubator-inlong/pull/2767#discussion_r815383498
##########
File path:
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/ConfigManager.java
##########
@@ -287,14 +288,15 @@ private boolean checkWithManager(String host, String
proxyClusterName) {
Map<String, String> groupIdToMValue = new HashMap<String,
String>();
Map<String, String> mqConfig = new HashMap<>();// include
url2token and other params
- if (configJson.getErrCode() == 0) {
+ if (configJson.isSuccess()) { //success get config
+ LOG.info("getConfig_v2 result: {}", returnStr);
/*
* get mqUrls <->token maps;
* if mq is pulsar, store format:
third-party-cluster.index1=cluster1url1,cluster1url2=token
* if mq is tubemq, token is "", store format:
third-party-cluster.index1=cluster1url1,cluster1url2=
*/
int index = 1;
- List<ThirdPartyClusterInfo> clusterSet =
configJson.getPulsarSet();
+ List<ThirdPartyClusterInfo> clusterSet =
configJson.getData().getMqSet();
Review comment:
There is a `configJson.isSuccess()` judgement in line 291. Only when
`mqSet` and `topicList` are not null, `configJson.isSuccess()` is true.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
