阿里云 DTS java 客户端配置

507 字
3 分钟
阿里云 DTS java 客户端配置

总是记不住阿里云 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 subscribeModeSDK客户端的使用模式,取值为:

ConsumerContext.ConsumerSubscribeMode.ASSIGN:ASSIGN模式,即一个消费组下仅支持一个SDK客户端消费订阅数据。

ConsumerContext.ConsumerSubscribeMode.SUBSCRIBE:SUBSCRIBE模式,即支持在同一个消费组下同时启动多个SDK客户端实现灾备。

Untitled 42|brokerUrl
Untitled 42|brokerUrl

Untitled 43|topic
Untitled 43|topic

Untitled 44|sid
Untitled 44|sid

Untitled 45|initCheckpoint
Untitled 45|initCheckpoint

📎 参考文章#

文章分享

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

阿里云 DTS java 客户端配置
https://blog.sephy.top/posts/阿里云-dts-java-客户端配置/
作者
虾米
发布于
2024-04-02
许可协议
CC BY-NC-SA 4.0
随机文章随机推荐
Profile Image of the Author
虾米
coder
分类
标签
站点统计
文章
61
分类
4
标签
52
总字数
64,663
运行时长
0
最后活动
0 天前
站点信息
构建平台
GitHub Actions
博客版本
Firefly v6.13.9
文章许可
CC BY-NC-SA 4.0