Skip to content

Commit

Permalink
Merge pull request #26 from ni-ze/quickStart
Browse files Browse the repository at this point in the history
doc(quick start) modify font size
  • Loading branch information
ni-ze authored Aug 3, 2022
2 parents 1a96fc9 + fa442fb commit 3e4e77f
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -35,24 +35,24 @@ docker ps
#进入rsqldb-client容器
docker exec -it ${rsqldb-client-containerId} bash
```
#### 提交任务
### 提交任务
```shell
sh clientExector.sh submitTask rocketmq.sql
```
rocketmq.sql任务从RocketMQ中rsqldb-source topic中读取数据,过滤出数据中首字段为1的数据,然后将结果写回到RocketMQ
中的rsqldb-sink topic中。
#### 开始任务
### 开始任务
```shell
sh clientExector.sh startTask
```

#### 向RocketMQ中写入数据
### 向RocketMQ中写入数据
```shell
java -cp RocketmqTest-1.0-SNAPSHOT.jar com.test.rocketmqtest.producer.Producer
```
向RocketMQ的rsqldb-source topic中写入RocketmqTest-1.0-SNAPSHOT.jar包中默认数据,数据如data.txt文件所示。
使用Producer类发送消息时,允许带三个参数:topic、groupId、数据文件全路径,可以向RocketMQ任意topic发送任意数据。
#### 查看结果输出
### 查看结果输出
```shell
java -cp RocketmqTest-1.0-SNAPSHOT.jar com.test.rocketmqtest.consumer.Consumer
```
Expand Down

0 comments on commit 3e4e77f

Please sign in to comment.