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 ff92d26b808f1f4695535cc5d98ba56e37d74237 Author: 维章 <[email protected]> AuthorDate: Fri May 27 18:52:25 2022 +0800 fix(example) join example --- .../org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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..31b3b831 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 @@ -23,7 +23,7 @@ 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") + DataStream right = StreamBuilder.dataStream("tmp", "tmp22") .fromRocketmq("TopicTest", "groupB", true, "localhost:9876"); left.join(right)
