Kafka客户端消费订阅数据

最近更新时间:2021-06-08 15:56:01

查看PDF

前提条件

注意事项

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

kafka客户端示例代码下载

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

kafka客户端示例代码说明

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

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

获取数据订阅所需信息

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

文档内容是否对您有帮助?

根本没帮助
文档较差
文档一般
文档不错
文档很好

在文档使用中是否遇到以下问题

内容不全,不深入
内容更新不及时
描述不清晰,比较混乱
系统或功能太复杂,缺乏足够的引导
内容冗长

更多建议

0/200

评价建议不能为空

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

问题反馈