华为云首页用户手册

事件网格 EG-分布式消息服务Kafka版:操作步骤

事件网格 EG-分布式消息服务Kafka版:操作步骤

时间：2024-06-27 11:05:03

事件网格 EG

操作步骤

登录事件网格控制台。
在左侧导航栏选择“事件流”，进入“事件流”页面。
单击“创建事件流”。
在弹窗中输入事件流名称和描述，单击“确定”，完成事件流名称和描述信息输入。

配置Kafka事件源。

单击“事件源”，右侧弹出“事件源”弹窗。
事件提供方选择“分布式消息服务 Kafka版”。

设置事件源参数。

图1 事件源-Kafka
点击放大

点击放大

表1 Kafka参数说明
参数名称	说明
实例	选择Kafka实例。
接入方式	选择“密文接入”或“明文接入”。
安全协议	当选择为密文接入时会显示对应的安全协议。
Topic	选择Topic。
消费组	输入消费组。
并发数	输入并发数，输入值范围1~1000。建议并发数与选择的Topic的分区数保持一致，如果不一致可能会影响消息消费速率。当您选择Topic时，如果并发数为空会读取您选择的Topic的分区数作为并发数。
消费点位	选择消费点位。最新点位：将会从消息队列的最新消息开始消费。最早点位：将会从消息队列的最早消息开始消费。
SASL认证机制	当Kafka实例开启SASL SSL时可见，选择SASL认证机制。 PLAIN：一种简单的用户名密码校验机制。 SC RAM -SHA-512：采用哈希算法对用户名与密码生成凭证，进行身份校验的安全认证机制，比PLAIN机制安全性更高。
SASL证书地址	当Kafka实例开启SASL SSL时可见，输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。说明：必须使用zip压缩包，压缩包内的文件数量不超过两个，压缩包和文件大小均不可超过1M；压缩包里证书的名称必须是固定的：client.jks。
SASL证书密钥	当Kafka实例开启SASL SSL时可见，输入SASL证书密钥。
用户名	当Kafka实例开启SASL SSL时可见，输入实例用户名。
用户密码	当Kafka实例开启SASL SSL时可见，输入实例用户密码。

单击“保存”，完成配置事件源。
完成配置事件源后，您可以参考路由到函数工作流，继续配置事件流的事件目标。
当事件源和事件目标都配置完成后，单击右上角“保存”，完成事件流的创建。

发送到目标端失败时，将重试整批事件，直到处理成功或源端消息过期为止，目标端需支持处理重复事件。

上一篇：事件网格 EG-事件轨迹:操作步骤

下一篇：事件网格 EG-事件通道:创建自定义事件通道

华为云11.11 2核1G 2M 云服务器

29元/年

立即注册领万元上云礼券

抽奖赢11111元免单

续费同价 L实例 2核2G 4M

98元/年

热门域名 1元随心购

1元/年

事件网格 EG-分布式消息服务Kafka版:操作步骤

意见反馈

0/200

提交成功！非常感谢您的反馈，我们会继续努力做到更好反馈提交失败！请稍后重试！

推荐文章

解决方案
相关专题