最近更新时间:2021-10-19 16:38:05
一个消费组对同一消息只能消费一次,如果希望实现对数据的多次消费,请新增消费组。
请查看kafka客户端示例代码
说明:关于代码使用的详细介绍,请参见示例中的说明。
代码中参数设置项详细说明如下
说明:可以通过DTS控制台获取对应参数的取值,详情请参见下方“获取数据订阅所需信息”。
参数名称 | 说明 |
---|---|
User | 消费组对应账号名称 |
Passwd | 该账号对应的密码 |
BrokerURL | 数据订阅的网络地址及端口号信息 |
GroupID | 消费组ID |
Topic | 数据订阅的消息主题 |
StartTime | 消息消费的起始时间。默认情况下,不需设置该值,即从订阅任务开始订阅全部消息;用户设置该值后,将强制订阅到该时间之后的消息,即为满足不同业务需求设置。 |
下面以KRDS for MySQL数据订阅为例,介绍如何获取数据订阅所需信息。
1、登录数据订阅控制台,在左侧导航栏选择数据订阅,进入数据订阅界面https://dts.console.ksyun.com/#/feed;
2、选择数据订阅所属地域,找到需要订阅的任务,单击该任务进入任务详情页;
3、在订阅任务详情页,可以获得订阅Topic和网络信息;
4、在任务详情页左侧选择数据消费,可以获得消费组ID及消费账号信息;
纯净模式