This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
commit 7981c2349689954fb3531dd5e33ec2088a6a3f31 Author: Heng Du <[email protected]> AuthorDate: Mon Aug 2 20:47:11 2021 +0800 Update README.md --- README.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index 92a9b2f..019ea63 100644 --- a/README.md +++ b/README.md @@ -13,7 +13,7 @@ import org.apache.rocketmq.streams.client.transform.DataStream; DataStreamSource source=StreamBuilder.dataStream("namespace","pipeline"); source - .fromFile("/Users/junjie.cheng/text.txt",false) + .fromFile("～/admin/data/text.txt",false) .map(message->message) .toPrint(1) .start(); @@ -104,4 +104,4 @@ source .toPrint(1) .with(CheckpointStrategy.db("jdbc:mysql://XXXXX:3306/XXXXX","","",0L)) .start(); -``` \ No newline at end of file +```
