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/03/02 03:39:35 UTC
[rocketmq-connect] 25/39: The topic name in the TaskTopicInfo constructor should be topic (#473)
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
commit 5ed354b5015a7a1d42f263e5f575b5c5699c3cc3
Author: zhoubo <87...@qq.com>
AuthorDate: Fri Nov 29 21:30:26 2019 +0800
The topic name in the TaskTopicInfo constructor should be topic (#473)
https://github.com/apache/rocketmq-externals/issues/470
---
.../java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java b/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java
index 3e2962b..b791b93 100644
--- a/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java
+++ b/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java
@@ -22,8 +22,8 @@ public class TaskTopicInfo extends MessageQueue {
private String targetTopic;
- public TaskTopicInfo(String sourceTopic, String brokerName, int queueId, String targetTopic) {
- super(sourceTopic, brokerName, queueId);
+ public TaskTopicInfo(String topic, String brokerName, int queueId, String targetTopic) {
+ super(topic, brokerName, queueId);
this.targetTopic = targetTopic;
}