全部文档
当前文档

暂无内容

如果没有找到您期望的内容,请尝试其他搜索词

文档中心

Kafka客户端消费订阅数据

最近更新时间:2021-10-19 16:38:05

前提条件

注意事项

一个消费组对同一消息只能消费一次,如果希望实现对数据的多次消费,请新增消费组。

kafka客户端示例代码下载

请查看kafka客户端示例代码
说明:关于代码使用的详细介绍,请参见示例中的说明。

kafka客户端示例代码说明

代码中参数设置项详细说明如下
说明:可以通过DTS控制台获取对应参数的取值,详情请参见下方“获取数据订阅所需信息”。

参数名称 说明
User 消费组对应账号名称
Passwd 该账号对应的密码
BrokerURL 数据订阅的网络地址及端口号信息
GroupID 消费组ID
Topic 数据订阅的消息主题
StartTime 消息消费的起始时间。默认情况下,不需设置该值,即从订阅任务开始订阅全部消息;用户设置该值后,将强制订阅到该时间之后的消息,即为满足不同业务需求设置。

获取数据订阅所需信息

下面以KRDS for MySQL数据订阅为例,介绍如何获取数据订阅所需信息。
1、登录数据订阅控制台,在左侧导航栏选择数据订阅,进入数据订阅界面https://dts.console.ksyun.com/#/feed;
2、选择数据订阅所属地域,找到需要订阅的任务,单击该任务进入任务详情页;
3、在订阅任务详情页,可以获得订阅Topic和网络信息;
image.png
4、在任务详情页左侧选择数据消费,可以获得消费组ID及消费账号信息;
image.png

文档导读
纯净模式常规模式

纯净模式

点击可全屏预览文档内容
文档反馈