事件网格 EG-实施及验证:源端配置操作步骤

时间：2024-11-04 15:52:14

事件网格 EG 基于事件流实现Kafka实例之间的数据同步

配置Kafka事件源。

设置事件源参数。

图1 事件源-Kafka
点击放大

表1 配置参数说明
参数名称	说明
实例	选择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时可见，输入实例用户密码。