From 1d265e1ac6b71e2811d80decbb5080a8d4f18024 Mon Sep 17 00:00:00 2001 From: huolibo Date: Mon, 15 Aug 2022 15:23:18 +0800 Subject: [PATCH] docs: add consumer.unsubscribe() --- .../src/main/java/com/taos/example/SubscribeDemo.java | 1 + docs/zh/07-develop/07-tmq.mdx | 10 +++++----- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/docs/examples/java/src/main/java/com/taos/example/SubscribeDemo.java b/docs/examples/java/src/main/java/com/taos/example/SubscribeDemo.java index b1e675cdf6..50e8b35771 100644 --- a/docs/examples/java/src/main/java/com/taos/example/SubscribeDemo.java +++ b/docs/examples/java/src/main/java/com/taos/example/SubscribeDemo.java @@ -68,6 +68,7 @@ public class SubscribeDemo { System.out.println(meter); } } + consumer.unsubscribe(); } } catch (ClassNotFoundException | SQLException e) { e.printStackTrace(); diff --git a/docs/zh/07-develop/07-tmq.mdx b/docs/zh/07-develop/07-tmq.mdx index 51a7d862ee..8565b6833a 100644 --- a/docs/zh/07-develop/07-tmq.mdx +++ b/docs/zh/07-develop/07-tmq.mdx @@ -185,14 +185,14 @@ TMQ支持多种订阅类型： | enable.heartbeat.background | 合法值：true, false | 开启后台心跳，即 consumer 不会因为长时间不 poll 而认为离线 | | experimental.snapshot.enable | 合法值：true, false | 从 wal 开始消费，还是从 tsbs 开始消费 | | msg.with.table.name | 合法值：true, false | 从消息中能否解析表名 | -| value.deserializer | value 值解析方法 | 此方法应实现 com.taosdata.jdbc.tmq.Deserializer 接口或是继承 com.taosdata.jdbc.tmq.ReferenceDeserializer 类 | -| value.deserializer.encoding | value 中使用字符编码集 | | +| value.deserializer | 指定 value 解析方法 | 此方法应实现 com.taosdata.jdbc.tmq.Deserializer 接口或是继承 com.taosdata.jdbc.tmq.ReferenceDeserializer 类 | +| value.deserializer.encoding | 指定 value 解析使用的字符编码集 | | ```java -import com.taosdata.jdbc.tmq.ReferenceDeserializer; + import com.taosdata.jdbc.tmq.ReferenceDeserializer; -public class MetersDeserializer extends ReferenceDeserializer { -} + public class MetersDeserializer extends ReferenceDeserializer { + } ``` ```java