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

时间:2024-06-27 11:04:52

操作步骤

  1. 登录事件网格控制台。
  2. 在左侧导航栏选择“事件流”,进入“事件流”页面。
  3. 单击“创建事件流”。
  4. 在弹窗中输入事件流名称和描述,单击“确定”,完成事件流名称和描述信息输入。
  5. 请参考配置分布式消息服务 Kafka版,配置事件源。
  6. 配置事件目标。

    1. 单击“事件目标”,右侧弹出“事件目标”弹窗。
    2. 目标服务选择“分布式消息服务 Kafka版”。
    3. 设置事件目标参数。
      图1 分布式消息服务 Kafka版
      表1 分布式消息服务 Kafka版参数说明

      参数名称

      说明

      目标连接

      选择目标连接。如果还未创建目标连接,请先创建分布式消息服务Kafka版目标连接,如何创建请参见目标连接

      Topic

      选择Topic。先选目标连接以加载Topic选项。

      消息Key配置

      关闭

      不启用消息Key。

      开启

      变量:从CloudEvents标准事件中获取变量值,将变量值作为Key值。

      常量:将指定的常量作为key值。若选择常量,所有消息将发送至同一分区。

      规则配置

      类型

      事件网格将CloudEvents标准事件转换成事件目标可以接受的事件类型。支持以下三种转换类型:
      • 透传:事件网格不对事件进行转换,将原生事件的完整结构直接路由到事件目标。
      • 变量:事件网格EventGrid通过JSONPath从事件中提取参数,然后把这些参数路由到事件目标。
      • 常量:事件只起到触发器的作用,不管事件内容是什么,事件网格都把常量路由到事件目标。

      如果需要了解更多转换类型的信息,请参考事件内容转换

      消息推送

      批量推送

      配置是否开启批量推送,批量推送可帮您批量聚合多个事件。

      批量推送条数

      推送间隔

      开启批量推送可见,每次批量推送的最大聚合条数,默认值100,输入值范围1~10000。

      开启批量推送可见,输入批量推送间隔,默认值1,输入值范围0~15,单位:秒。

support.huaweicloud.com/usermanual-eg/eg-ug-076.html