Kafka触发器可以订阅分布式消息Kafka并根据消息触发关联的函数,借此能力,使得函数可以消费指定Kafka的消息,执行自定义处理逻辑。
注意事项
Kafka触发器订阅的分布式消息Kafka实例必须和函数计算的函数实例在相同地域,
前提条件
- 已创建函数
- 已开通分布式消息Kafka实例(KAFKA引擎版),详情请参考创建分布式消息服务Kafka实例。
- 已创建Topic
操作步骤
-
登录函数计算控制台,在左侧菜单栏选择函数菜单。
-
在函数列表中选择目标函数,进入函数详情页。
-
在函数详情中,在配置栏下选择触发器, 点击创建触发器, 在弹出的界面中,触发器类型选择消息队列KAFKA触发器,填写相关配置,然后点击确定。可参考以下配置项说明。
配置项 | 操作 | 示例 |
---|---|---|
触发器类型 | 选择消息队列Kafka触发器 | 消息队列Kafka触发器 |
名称 | 填写自定义的触发器名称。 | kafka-trigger |
版本或别名 | 默认值为LATEST,支持选择任意函数版本或函数别名 | LATEST |
Kafka 实例 | 选择已创建的Kafka实例 | |
Topic | 选择已创建的Kafka实例的Topic。 | |
Group ID | 1、快速创建:推荐方案。自动创建以 GID_FC_TRIGGER_{trigger_name}_{timestamp} 命名的 Group ID。 2、使用已有:选择Kafka实例已有的GroupID,请您注意不要与已有的业务混用GroupID,否则会影响已有的消息收发。 |
|
消费任务并发数 | 消费者的并发数量,取值范围为[1,Topic的分区数]。 | |
消费位点 | 选择消息的消费位点,即触发器从kafka消息队列开始拉取消息的位置。 最早位点:从最早位点开始消费。 最新位点:从最新位点开始消费。 |
最新位点 |
调用方式 | 选择函数调用方式。 1、同步调用:适用于顺序调用场景。单个消息触发函数调用,等待函数执行完成返回结果后,再由下一个消息继续触发函数调用 2、异步调用:可以快速消费事件。单个消息触发异步函数调用,不等待函数执行,直接由下一个消息继续触发函数调用。 |
同步调用 |
触发器启用状态 | 创建触发器后是否立即启用。默认选择开启,即创建触发器后立即启用触发器。 | 启用 |