使用分布式消息服务 Kafka版（KAFKA）触发器

更新时间：2025-09-12 GMT+08:00

查看PDF

本节介绍如何通过函数工作流控制台创建Kafka触发器，以实现FunctionGraph对Kafka实例中指定Topic的新消息进行定期轮询。FunctionGraph会将轮询得到的消息作为参数，用于调用相应函数。

关于Kafka触发器的事件源介绍，请参见支持的事件源。

说明：

分布式消息服务Kafka版与开源Kafka的差异说明，请参见Kafka与开源Kafka的差异。

函数及其配置：
- 已创建函数。
- 已配置函数的分布式消息服务DMS委托权限，委托的创建请参见配置函数的委托权限。
- 请参见配置网络开启函数访问VPC内资源的网络配置。
分布式消息服务Kafka：
- 已创建Kafka实例，创建操作请参见购买Kafka专享版实例。
- 在Kafka实例下创建主题，创建操作请参见Kafka实例创建Topic。
- 开启函数访问VPC内资源后，请参见在Kafka服务安全组配置对应子网的权限。

配置以下参数。

表1 Kafka触发器参数说明
参数	说明	取值样例
触发器类型	选择“分布式消息服务 Kafka版 (KAFKA)”。	分布式消息服务 Kafka版 (KAFKA)
实例	选择已创建的Kafka实例。若无实例，可单击“创建实例”完成创建。	kafka-fg
主题	选择专享版Kafka实例的Topic。Kafka触发器当前支持选择多个Topic主题，从而避免Topic过多导致创建的触发器数量被限制。若无主题，可单击“创建主题”完成创建。	topic-fg
批处理大小	输入每次从Topic消费的消息数量，设置范围：1~1000。	100
用户名	Kafka实例开启SSL时需要填写。连接Kafka专享版实例的用户名。	user
密码	Kafka实例开启SSL时需要填写。连接Kafka专享版实例的密码。	***

填写如表2所示测试信息后，单击“保存”。

表2 测试信息
参数	说明	取值样例
配置测试事件	可创建新的测试事件也可编辑已有的测试事件。默认值为“创建新的测试事件”。	创建新的测试事件
事件模板	选择"分布式消息服务 Kafka版（KAFKA）"模板，使用系统内置Kafka事件模板。	分布式消息服务 Kafka版（KAFKA）
事件名称	事件名称必须以大写或小写字母开头，支持字母（大写或小写），数字和下划线“_”（或中划线“-”），并以字母或数字结尾，长度为1-25个字符。	kafka-123test
测试事件	自动加载系统内置kafka事件模板，本例不做修改。	-

提供反馈

提交成功！非常感谢您的反馈，我们会继续努力做到更好！

系统繁忙，请稍后重试

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

内容与产品页面不一致

内容不易理解

缺失示例代码

步骤不可操作

搜不到想要的内容

缺少最佳实践

意见反馈（选填）

0/500

请至少选择一项反馈信息并填写问题反馈

字符长度不能超过500

直接提交取消