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 0bcaf5bf92b03448b22eb472da9a01c0b52df6f3 Merge: 4d94b411 5a236975 Author: 维章 <[email protected]> AuthorDate: Mon May 30 15:11:56 2022 +0800 modify topic .../apache/rocketmq/streams/examples/join/RocketmqJoinExample.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --cc rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java index 31b3b831,30dec798..8d79e076 --- 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,10 -22,10 +22,11 @@@ import org.apache.rocketmq.streams.clie public class RocketmqJoinExample { public static void main(String[] args) { DataStream left = StreamBuilder.dataStream("tmp", "tmp") - .fromRocketmq("TopicTest", "groupA", true, "localhost:9876"); + .fromRocketmq("TopicTestJoin", "groupA", true, "localhost:9876"); DataStream right = StreamBuilder.dataStream("tmp", "tmp22") - .fromRocketmq("TopicTest", "groupB", true, "localhost:9876"); + .fromRocketmq("TopicTestJoin", "groupB", true, "localhost:9876"); + + left.join(right) .on("(ProjectName,=,ProjectName)") .toDataSteam()
