更新时间：2024-09-06 GMT+08:00
分布式消息服务Kafka版
本章节介绍在创建事件流时，如何配置分布式消息服务Kafka版实例为事件源。
前提条件
操作步骤
- 登录事件网格控制台。
- 在左侧导航栏选择“事件流 > Serverless版事件流”，进入“Serverless版事件流”页面。
- 单击“创建Serverless版事件流”，然后单击左上角
图标，输入事件流名称和描述，完成后单击“确定”。 - 配置Kafka事件源。
- 单击“事件源”，右侧弹出“事件源”弹窗。
- 事件提供方选择“分布式消息服务 Kafka版”。
- 设置事件源参数。
图1 事件源-Kafka
表1 Kafka参数说明 参数名称
说明
实例
选择Kafka实例。
接入方式
选择“密文接入”或“明文接入”。
安全协议
当选择为密文接入时会显示对应的安全协议。
Topic
选择Topic。
消费组
输入消费组名称，输入长度范围为3到64个字符。
- Kafka实例未创建消费组时，事件流启动用后，Kafka实例会自动创建输入的消费组，详情请参见查看Kafka消费组信息。
- Kafka实例已创建消费组时，此处输入创建好的消费组名称即可，详情请参见创建Kafka消费组。
并发数
输入并发数，输入值范围1~1000。
建议并发数与选择的Topic的分区数保持一致，如果不一致可能会影响消息消费速率。当您选择Topic时，如果并发数为空会读取您选择的Topic的分区数作为并发数。
消费点位
选择消费点位。
- 最新点位：将会从消息队列的最新消息开始消费。
- 最早点位：将会从消息队列的最早消息开始消费。
SASL认证机制
当Kafka实例开启SASL SSL时可见，选择SASL认证机制。
- PLAIN：一种简单的用户名密码校验机制。
- SCRAM-SHA-512：采用哈希算法对用户名与密码生成凭证，进行身份校验的安全认证机制，比PLAIN机制安全性更高。
SASL证书地址
当Kafka实例开启SASL SSL时可见，输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。
说明：- 必须使用zip压缩包，压缩包内的文件数量不超过两个，压缩包和文件大小均不可超过1M；
- 压缩包里证书的名称必须是固定的：client.jks。
- SASL证书被修改时，为保证证书加载生效需区分如下两种情况：
- 当SASL证书文件名称被修改时，请重新获取证书地址并完成输入，然后单击“保存”。
- 当SASL证书文件名称未修改时，如果其他参数也未修改，则证书不会重新加载，只有当“Topic”、“消费组”、“SASL认证机制”、“SASL证书密钥”、“用户名”和“用户密码”中至少一项参数修改时，单击“保存”后，证书才会重新加载。
SASL证书密钥
当Kafka实例开启SASL SSL时可见，输入SASL证书密钥。
用户名
当Kafka实例开启SASL SSL时可见，输入实例用户名。
用户密码
当Kafka实例开启SASL SSL时可见，输入实例用户密码。
- 单击“保存”，完成配置事件源。
- 完成配置事件源后，您可以参考路由到函数工作流，继续配置事件流的事件目标。
- 当事件源和事件目标都配置完成后，单击右上角“保存”，完成事件流的创建。
发送到目标端失败时，将重试整批事件，直到处理成功或源端消息过期为止，目标端需支持处理重复事件。
父主题： 事件源
