[rocketmq-streams] 13/16: modify topic

[ka...@apache.org]

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: 维章 <un...@gmail.com>
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()