You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/12/26 08:34:37 UTC
[rocketmq-connect] branch master updated: fix: connect status topic should have the same prefix with others (#396)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
The following commit(s) were added to refs/heads/master by this push:
new 8b007ec9 fix: connect status topic should have the same prefix with others (#396)
8b007ec9 is described below
commit 8b007ec944a7fe918257d86295296285da55cd88
Author: Vincent Lee <co...@gmail.com>
AuthorDate: Mon Dec 26 16:34:31 2022 +0800
fix: connect status topic should have the same prefix with others (#396)
Change-Id: I667397d3f67b5c90a85b7bcccc52342ee0d2816e
Co-authored-by: liwen.2022 <li...@bytedance.com>
---
.../java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java
index 9bfbddfb..fcef3125 100644
--- a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java
+++ b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java
@@ -146,7 +146,7 @@ public class WorkerConfig {
/**
* Default topic to send/consume state change message.
*/
- private String connectStatusTopic = "connect-status-topic";
+ private String connectStatusTopic = "connector-status-topic";
/**
* Connector state persistence interval.
@@ -587,4 +587,4 @@ public class WorkerConfig {
", metricsConfig=" + metricsConfig +
'}';
}
-}
\ No newline at end of file
+}