[inlong] branch master updated: [INLONG-8580][Manager] Error in pushing topic information when using TubeMQ (#8581)

[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/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 1e05683f55 [INLONG-8580][Manager] Error in pushing topic information 
when using TubeMQ (#8581)
1e05683f55 is described below

commit 1e05683f556185d88d67b5794f35b737340f009e
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Thu Jul 20 12:53:07 2023 +0800

    [INLONG-8580][Manager] Error in pushing topic information when using TubeMQ 
(#8581)
---
 .../inlong/manager/service/source/tubemq/TubeMQSourceOperator.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/tubemq/TubeMQSourceOperator.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/tubemq/TubeMQSourceOperator.java
index e3abc4575c..7fc56539d9 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/tubemq/TubeMQSourceOperator.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/tubemq/TubeMQSourceOperator.java
@@ -106,7 +106,7 @@ public class TubeMQSourceOperator extends 
AbstractSourceOperator {
             TubeMQSource tubeMQSource = new TubeMQSource();
             String streamId = streamInfo.getInlongStreamId();
             tubeMQSource.setSourceName(streamId);
-            tubeMQSource.setTopic(streamInfo.getMqResource());
+            tubeMQSource.setTopic(groupInfo.getMqResource());
             tubeMQSource.setGroupId(streamId);
             tubeMQSource.setMasterRpc(masterRpc);
             tubeMQSource.setIgnoreParseError(streamInfo.getIgnoreParseError());