腾讯云产品

数据订阅 Kafka 版（当前 Kafka Server 版本为V2.6.0）中，针对 Avro 格式的订阅数据，可以使用 Flink 客户端（仅支持客户端类型为 DataStream API）进行消费，本场景提供使用 flink-dts-connector 进行数据消费的 Demo 示例。

导入数据，支持 csv、xml 两种数据格式，如果记录存在更新记录，如果记录不存在新增记录。

Demo 中我们采用 JSON 进行序列化，各语言 Demo 中均附带有 Record 定义文件。
Java Demo 中的定义文件路径为： consumerDemo-json-java\\src\\main\\java\\json\\FlatRecord.java。

这篇说说腾讯云DTS数据同步任务的销毁与退货操作，说明隔离后7天自动下线，并建议及时销毁已完成任务以解冻按量计费预冻结费用。 销毁/退货：结束或失败任务可销毁，包年包月可退货，隔离后7天自动下线。 恢复方式：按量计费实例可通过解隔离恢复，包年包月实例可通过续费恢复。 费用说明：按量计费模式预冻结1小时费用，销毁后解冻，建议及时操作。

标签是腾讯云提供的用于标识云上资源的标记，是一个键-值对（Key-Value）可以以根据不同维度（例如，业务、用途、负责人等）使用标签，对游戏数据库 TcaplusDB 资源进行分类管理。通过标签可以非常方便地筛选过滤出对应的资源。标签键值对腾讯云没有任何语义意义，会严格按字符串进行解析匹配，在使用过程中仅需注意对应的 使用限制 即可。

在任务启动后，如果源数据库连接数过多或者业务需要调整，用户可以选择暂停任务，待业务调整完成后继续同步任务。

当开启全局索引功能后，TcaplusDB 将支持按照普通字段查询，查询条件中的字段必须是建立了全局索引的字段。
如果是聚合查询，那么聚合查询的字段也必须是建立了全局索引的字段。
一个索引查询请求，最多返回3000条记录。

这篇排查DTS连通性测试失败问题，原因包括网络ACL/安全组限制、防火墙、数据库IP规则、端口未放通、账号授权及密码错误，并给出对应处理步骤。 网络放通：需在ACL、安全组、防火墙及数据库IP规则中放通DTS服务IP。 账号授权：检查账号授权范围，避免仅限指定IP访问，需重新授权为全IP可访问。 端口与接入类型：确认默认端口已放通，且连通性校验通过后勿切换接入类型。

对于状态为任务错误、任务失败，并且状态持续14天的任务，因为任务本身已无法再进行重连，系统将自动将这些任务状态扭转为结束的状态。

这篇说明腾讯云DTS数据订阅实例的销毁与退货操作，任务销毁后不再计费，包年包月实例可申请退费，实例进入回收站保留7天后自动下线。 销毁：适用于已结束或失败的实例任务，销毁后不再存在且停止计费。 退货：包年包月实例可退货退费，操作后实例进入回收站不可恢复。