You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/10/10 12:25:03 UTC
[rocketmq-flink] branch main updated: Update README.md (#10)
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-flink.git
The following commit(s) were added to refs/heads/main by this push:
new 8dd74ef Update README.md (#10)
8dd74ef is described below
commit 8dd74efb0aef2dd9cc1db692d558eb3d9137df73
Author: Utopia <ge...@gmail.com>
AuthorDate: Sun Oct 10 20:24:58 2021 +0800
Update README.md (#10)
rename "RocketMqConfig" to "RocketMQConfig"
---
README.md | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/README.md b/README.md
index 22db0a8..769b349 100644
--- a/README.md
+++ b/README.md
@@ -65,12 +65,12 @@ StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironm
env.enableCheckpointing(3000);
Properties consumerProps = new Properties();
- consumerProps.setProperty(RocketMqConfig.NAME_SERVER_ADDR, "localhost:9876");
- consumerProps.setProperty(RocketMqConfig.CONSUMER_GROUP, "c002");
- consumerProps.setProperty(RocketMqConfig.CONSUMER_TOPIC, "flink-source2");
+ consumerProps.setProperty(RocketMQConfig.NAME_SERVER_ADDR, "localhost:9876");
+ consumerProps.setProperty(RocketMQConfig.CONSUMER_GROUP, "c002");
+ consumerProps.setProperty(RocketMQConfig.CONSUMER_TOPIC, "flink-source2");
Properties producerProps = new Properties();
- producerProps.setProperty(RocketMqConfig.NAME_SERVER_ADDR, "localhost:9876");
+ producerProps.setProperty(RocketMQConfig.NAME_SERVER_ADDR, "localhost:9876");
env.addSource(new RocketMQSource(new SimpleKeyValueDeserializationSchema("id", "address"), consumerProps))
.name("rocketmq-source")