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 <[email protected]>
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")

Reply via email to