[incubator-inlong] branch master updated: [INLONG-3568][TubeMQ] Nodes realize batch online, offline, and reloading (#3569)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 1bd2caacb [INLONG-3568][TubeMQ] Nodes realize batch online, offline, 
and reloading (#3569)
1bd2caacb is described below

commit 1bd2caacb6db112151fac7823cf0448144dd92e5
Author: bluewang <88174078+bluew...@users.noreply.github.com>
AuthorDate: Thu Apr 7 20:53:54 2022 +0800

    [INLONG-3568][TubeMQ] Nodes realize batch online, offline, and reloading 
(#3569)
---
 .../tubemq/manager/controller/node/request/OnlineOfflineBrokerReq.java  | 2 +-
 .../inlong/tubemq/manager/controller/node/request/ReloadBrokerReq.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/OnlineOfflineBrokerReq.java
 
b/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/OnlineOfflineBrokerReq.java
index 533031a7d..9c27ddc0e 100644
--- 
a/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/OnlineOfflineBrokerReq.java
+++ 
b/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/OnlineOfflineBrokerReq.java
@@ -25,7 +25,7 @@ import lombok.ToString;
 @EqualsAndHashCode(callSuper = true)
 @ToString(callSuper = true)
 public class OnlineOfflineBrokerReq extends BaseReq {
-    private Integer brokerId;
+    private String brokerId;
     private String modifyUser;
     private String confModAuthToken;
 }
diff --git 
a/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/ReloadBrokerReq.java
 
b/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/ReloadBrokerReq.java
index 6efb6cb2c..d71681a03 100644
--- 
a/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/ReloadBrokerReq.java
+++ 
b/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/ReloadBrokerReq.java
@@ -25,7 +25,7 @@ import lombok.ToString;
 @EqualsAndHashCode(callSuper = true)
 @ToString(callSuper = true)
 public class ReloadBrokerReq extends BaseReq {
-    private Integer brokerId;
+    private String brokerId;
     private String modifyUser;
     private String confModAuthToken;
 }