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
+}