opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-17 17:17:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

removed typos and spelling errors from comments in quickstart (#3572)

Browse Source
This commit is contained in:
Naman rai
2021-12-02 15:52:06 +08:00
committed by GitHub
parent d6f3ed6c1a
commit 16cabf020c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java
+2 -2
View File
@@ -50,12 +50,12 @@ public class Consumer {
*/
/*
* Specify where to start in case the specified consumer group is a brand new one.
* Specify where to start in case the specific consumer group is a brand-new one.
*/
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
/*
* Subscribe one more more topics to consume.
* Subscribe one more topic to consume.
*/
consumer.subscribe("TopicTest", "*");