507 字

3 分钟

阿里云 DTS java 客户端配置

2024-04-02

无标签

浏览量加载中...

总是记不住阿里云 dts java sdk 的配置, 记录一下

参数	说明	获取方式
brokerUrl	数据订阅通道的网络地址及端口号信息。说明如果您部署SDK客户端所属的ECS实例与数据订阅通道属于经典网络或同一专有网络，建议通过内网地址进行数据订阅，网络延迟最小。	在DTS控制台单击目标订阅实例ID，在基本信息页面的网络区域，您可以获取网络地址及端口号信息。
topic	数据订阅通道的订阅Topic。	在DTS控制台单击目标订阅实例ID，在基本信息页面的基本信息区域，您可以获取到订阅Topic。
sid	消费组ID。	在DTS控制台单击目标订阅实例ID，然后单击数据消费，您可以获取到消费组ID和消费组的账号信息。
userName	消费组的账号。警告如您未使用本文提供的客户端，请按照<消费组的账号>-<消费组ID>的格式设置用户名（例如：dtstest-dtsae******bpv），否则无法正常连接。
password	该账号的密码。
initCheckpoint	消费位点，即SDK客户端消费第一条数据的时间戳，格式为Unix时间戳，例如1620962769。说明消费位点信息可用于：当业务程序中断后，传入已消费位点继续消费数据，防止数据丢失。在订阅客户端启动时，传入所需的消费位点，调整订阅位点，实现按需消费数据。
ConsumerContext.ConsumerSubscribeMode subscribeMode	SDK客户端的使用模式，取值为： ConsumerContext.ConsumerSubscribeMode.ASSIGN：ASSIGN模式，即一个消费组下仅支持一个SDK客户端消费订阅数据。 ConsumerContext.ConsumerSubscribeMode.SUBSCRIBE：SUBSCRIBE模式，即支持在同一个消费组下同时启动多个SDK客户端实现灾备。

Untitled 42|brokerUrl

Untitled 43|topic

Untitled 44|sid

Untitled 45|initCheckpoint

📎 参考文章#

使用SDK示例代码消费订阅数据_数据传输服务(DTS)-阿里云帮助中心 (aliyun.com)

文章分享

如果这篇文章对你有帮助，欢迎分享给更多人！

阿里云 DTS java 客户端配置

https://blog.sephy.top/posts/alicloud-dts-java-client-configuration/

作者

虾米

发布于

2024-04-02

许可协议

CC BY-NC-SA 4.0

Docker 常用操作

MySQL 中的锁

相关文章智能推荐

zsh Tab 补全卡住排查：iTerm2 tmux Control Mode 与 fzf-tab popup 冲突

技术分享记录一次 zsh Tab 补全问题的排查：先为 completion 增加大小写不敏感匹配，再定位 iTerm2 tmux Control Mode 下 fzf-tab popup 后端导致远程 shell 看似卡住的问题，并用条件配置修复。

从一票海运入仓开始，梳理海外仓常见业务术语

业务用一批家具从宁波港发往洛杉矶海外仓的例子，串起 FCL、LCL、ETD、ETA、LFD、Demurrage、Detention 等常见术语。

团队多人协同维护项目时，如何统一管理 skill

AI把项目级 skill 当成依赖管理，解决团队成员使用不同版本和不同规则的问题。

重新认识 .gitignore：目录级规则与 .git/info/exclude

编程从目录级 .gitignore 的作用域、匹配优先级和常见陷阱出发，理解 Git 的忽略机制，并掌握 .git/info/exclude 的使用方法。

把 GitHub Action 抽成跨项目复用

服务器记录把飞书通知 Action 从单个项目迁移到共享 actions 仓库后的使用方式。

随机文章随机推荐

评论区

分享你的想法，与大家交流讨论