事件网格 EG-实施及验证:目标端配置操作步骤
目标端配置操作步骤
- 登录事件网格控制台。
- 在左侧导航栏选择“事件流”,进入“事件流”页面。
- 单击“创建事件流”。
- 配置事件目标。
- 单击“事件目标”,右侧弹出“事件目标”弹窗。
- 目标服务选择“分布式消息服务 Kafka版”。
- 设置事件目标参数。
图2 分布式消息服务 Kafka版
表2 分布式消息服务 Kafka版参数说明 参数名称
说明
目标连接
选择目标连接。如果还未创建目标连接,请先创建分布式消息服务Kafka版目标连接。
Topic
选择Topic。先选目标连接以加载Topic选项。
消息Key配置
关闭
不启用消息Key。
开启
变量:从CloudEvents标准事件中获取变量值,将变量值作为Key值。
常量:将指定的常量作为key值。若选择常量,所有消息将发送至同一分区。
规则配置
类型
变量:data.value
如果需要了解更多转换类型的信息,请参考事件内容转换。
消息推送
批量推送
配置是否开启批量推送,批量推送可帮您批量聚合多个事件。
批量推送条数
推送间隔
开启批量推送可见,每次批量推送的最大聚合条数,默认值100,输入值范围1~10000。
开启批量推送可见,输入批量推送间隔,默认值1,输入值范围0~15,单位:秒。
事件目标kafka不支持自定义证书。
表3 批量推送示例 批量推送条数
推送间隔
实际发送效果
100条
1s
每隔1s批量推送100条消息
200条
5s
每隔5s批量推送500条消息
- 配置完成后,单击“确定”。
- 单击“事件流列表”操作列的“启用”,待状态列显示为“运行中”则代表整个链路创建成功。