Skip to content

Commit

Permalink
Merge pull request #233 from ni-ze/newWorld-4
Browse files Browse the repository at this point in the history
[ISSUE #234]Add quick start
  • Loading branch information
ni-ze authored Jan 3, 2023
2 parents 5ed57f1 + e3a98a2 commit 0dd886e
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -81,12 +81,15 @@ The broker[broker-a, 192.169.1.2:10911] boot success...
```

**3) Build stream processing application**

* create topic in RocketMQ before start the stream processing.
```shell
sh bin/mqadmin updateTopic -c DefaultCluster -t sourceTopic -r 8 -w 8 -n 127.0.0.1:9876
```
NOTE: the default clusterName is DefaultCluster in this quick-start doc, changes with your RocketMQ cluster.

NOTE: the default clusterName is DefaultCluster in this quick-start doc, changes it with your RocketMQ cluster.

* add your stream processing code, follow is the example. more example is [here](./example/src/main/java/org/apache/rocketmq/streams/examples).
```java
public static void main(String[] args) {
StreamBuilder builder = new StreamBuilder("wordCount");
Expand Down

0 comments on commit 0dd886e

Please sign in to comment.