diff --git a/docs/zh/07-develop/07-tmq.mdx b/docs/zh/07-develop/07-tmq.mdx index 8ab155948b4278ca0338321fb3a20ff4ebd99157..f36f76fd8565966dae8e20a31cc2d6903b5d26db 100644 --- a/docs/zh/07-develop/07-tmq.mdx +++ b/docs/zh/07-develop/07-tmq.mdx @@ -238,6 +238,9 @@ public class MetersDeserializer extends ReferenceDeserializer { 一个 consumer 支持同时订阅多个 topic。 + + + ```c // 创建订阅 topics 列表 tmq_list_t* topicList = tmq_list_new(); @@ -248,8 +251,23 @@ tmq_list_destroy(topicList); ``` + + + +```java +List topics = new ArrayList<>(); +topics.add("tmq_topic"); +consumer.subscribe(topics); +``` + + + + + ## 消费 +以下代码展示了不同语言下如何对 TMQ 消息进行消费。 + @@ -267,10 +285,6 @@ while (running) { ```java -List topics = new ArrayList<>(); -topics.add("tmq_topic"); -consumer.subscribe(topics); - while(running){ ConsumerRecords meters = consumer.poll(Duration.ofMillis(100)); for (Meters meter : meters) { @@ -284,6 +298,8 @@ while(running){ ## 结束消费 +消费结束后,应当取消订阅。 +