This is an automated email from the ASF dual-hosted git repository. karp pushed a commit to branch snapshot-1.0.4 in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
commit 5a236975a497a970c43f5b576ece46b5502812cb Author: 维章 <[email protected]> AuthorDate: Mon May 30 15:10:28 2022 +0800 fix(example) join example --- .../apache/rocketmq/streams/examples/join/RocketmqJoinExample.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java index f4270d8a..30dec798 100644 --- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java +++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java @@ -22,9 +22,9 @@ import org.apache.rocketmq.streams.client.transform.DataStream; public class RocketmqJoinExample { public static void main(String[] args) { DataStream left = StreamBuilder.dataStream("tmp", "tmp") - .fromRocketmq("TopicTest", "groupA", true, "localhost:9876"); - DataStream right = StreamBuilder.dataStream("tmp", "tmp") - .fromRocketmq("TopicTest", "groupB", true, "localhost:9876"); + .fromRocketmq("TopicTestJoin", "groupA", true, "localhost:9876"); + DataStream right = StreamBuilder.dataStream("tmp", "tmp22") + .fromRocketmq("TopicTestJoin", "groupB", true, "localhost:9876"); left.join(right) .on("(ProjectName,=,ProjectName)")
