函数服务支持对接火山引擎的 消息队列 Kafka 版。 通过创建 Kafka 触发器，函数服务将作为消费者消费 Kafka 中的消息，并将消息传递给用户函数，触发函数代码逻辑。您无需关心函数服务消费消息的细节，只需编写处理消息的函数。本文为您介绍如何创建 Kafka 触发器。

前提条件

• 函数已开启 VPC 访问功能，要求函数与待消费的 Kafka 实例处于同一 VPC 下。 详细操作可参见 函数配置。
• 函数开启或修改 VPC 访问配置后，需重新完成全量发布。详细操作可参见 发布函数。
• 已创建 Kafka 实例和 Topic，且已为当前 Kafka 实例创建 SASL 用户。其中，SASL 用户需至少具备目标 Topic 的读权限。详细操作可参见 消息队列 Kafka 版快速入门。

使用限制

• 每个函数最多支持创建 20 个触发器。
• Kafka 实例和函数必须处于同一 VPC 下。
• 若需要修改函数的 VPC 或子网，必须先停用或删除所有的 MQ 触发器。
• Kafka 触发器创建成功后，不支持变更 Kafka 实例、 Topic 及消费位置。

操作步骤

1. 登录 函数服务控制台。

2. 在顶部导航栏，选择目标地域。

3. 在 函数列表 页面，选择需要创建触发器的函数，单击函数名称。

4. 在函数详情页面的 触发器 页签下，单击 创建触发器。

5. 在 创建触发器 面板，按要求设置参数。
   

   配置项	说明
   触发器类型	本场景选择 Kafka 触发器。
   触发器名称	自定义触发器名称。同一函数下，触发器名称不可重复。触发器名称创建成功后不支持修改。
   实例	即 Kafka 实例，函数服务将扮演消费者，去消费指定 Kafka 实例下指定 Topic 中的消息。请选择前提条件中准备好的 Kafka 实例和 Topic。 Topic：消息主题，表示一类消息的集合，是消息队列 Kafka 版进行消息订阅的基本单位。 说明 仅支持选择与函数处于同一 VPC 下的 Kafka 实例。
   重试次数	函数发生运行错误（包括用户代码错误和 Runtime 错误）时的最大重试次数。
   指定消费位置	指定开始消费 Topic 中消息的位置，支持从头消费和从最新消费两种类型。请根据业务需要进行选择，指定消费位置后不支持变更。 从头消费：从 Topic 中生产的第一条消息开始消费。 从最新消费：只消费订阅 Topic 后产生的消息。
   立即启用	是否在创建触发器的同时启用触发器。只有处于启用状态的触发器才能够正常工作。
   身份认证	输入前提条件中准备好的访问 Kafka 实例的 SASL 用户名及密码。函数服务会通过 Kafka ACL 权限策略，对 PLAIN 和 SCRAM 两种类型的 SASL 用户进行消息消费鉴权。 注意 请输入正确的 SASL 用户名及密码，用户名密码错误将导致函数无法消费 Kafka 消息。 请确保配置的 SASL 用户至少具备目标 Topic 的读权限。
   备注	根据需要输入备注信息。

6. 单击 确定，完成 Kafka 触发器创建。

后续操作

• 如果您需要修改 Kafka 触发器，可参考 管理触发器。
• 如果您需要观测函数的运行状态，可参考 监控与日志。