检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
重试间隔（毫秒） 请输入1000到30000之间的整数。 表2 RockrtMQ 4.x版本重试时间间隔 第几次重试 与上次重试的间隔时间 第几次重试 与上次重试的间隔时间 1 10秒 9 7分钟 2 30秒 10 8分钟 3 1分钟 11 9分钟 4 2分钟 12 10分钟
M项目，不支持企业项目，表示仅能在IAM中给用户组授权并生效，如果在企业管理中授权，则该自定义策略不生效。关于IAM项目与企业项目的区别，详情请参见：IAM与企业管理的区别。 事件网格支持的自定义策略授权项如下表所示。用户调用如下API时，需要获取对应的权限。权限获取请参考统一身份认证服务（IAM）的帮助指导。
请输入0到450之间的整数。 单击“下一步”，进入规则配置页面，规则配置可参考过滤规则参数说明。 图2 规则配置 单击“下一步”完成规则配置，您可以参考路由到函数工作流，继续配置事件流的事件目标。 事件源配置为移动云RocketMQ版时，配置事件目标为FunctionGraph（函数计算）时，执行方式可选择为“同步”或“异步”。
请输入1到32之间的整数。 单击“下一步”，进入规则配置页面，规则配置可参考过滤规则参数说明。 图2 规则配置 单击“下一步”完成规则配置，您可以参考路由到函数工作流，继续配置事件流的事件目标。 事件源配置为社区版RocketMQ时，配置事件目标为FunctionGraph（函数计算）时，执行方式可选择为“同步”或“异步”。
Kafka实例开启SASL_SSL认证时可见，选择SASL_SSL 认证机制。 PLAIN：一种简单的用户名密码校验机制。 SCRAM-SHA-512：采用哈希算法对用户名与密码生成凭证，进行身份校验的安全认证机制，比PLAIN机制安全性更高。 用户名 Kafka实例开启SASL_SSL认证时可见，输入实例用户名。
专享版事件流概述 事件网格（EventGrid，简称EG）专享版事件流作为易用、稳定、高效的数据同步管道连接不同的系统与服务，支持中间件数据在线实时同步。事件流围绕云中间件，降低了中间件之间数据流通的复杂性，有效地帮助您减少数据传输的成本。适用于上云、跨云、云内跨地域中间件数据搬
7及以上，后续支持版本会持续更新。 源Kafka和目标Kafka实例的规格、存储空间需保持一致。 确保vpc、子网、kafka等资源充足。 确保源端和目标端实例与用户创建事件流集群时选择的VPC网络互通。 创建VPC和子网的操作指导请参考创建虚拟私有云和子网。 操作步骤 登录事件网格控制台。 在左侧导
检查事件流集群创建页面中配置的vpc和子网是否与源端Kafka实例网络畅通。 原因二：无法连接源端Kafka实例，请检查填写的实例信息是否正确。 解决方案： 进入Kafka的控制台页面，检查源端实例状态是否正常。 检查事件流集群创建页面中配置的vpc和子网是否与源端Kafka实例网络畅通。 检
检查事件流集群创建页面中配置的vpc和子网是否与源端RocketMQ实例网络畅通。 原因二：无法连接源端RocketMQ实例，请检查填写的实例信息是否正确。 解决方案： 进入RocketMQ的控制台页面，检查源端实例状态是否正常。 检查事件流集群创建页面中配置的vpc和子网是否与源端实例网络畅通。 检查
不受企业项目的划分影响。 企业可以根据不同的部门或项目组，将相关的资源放置在相同的企业项目内进行管理，并支持资源在企业项目之间迁移。 项目与企业项目的区别 IAM项目是针对同一个区域内的资源进行分组和隔离，是物理隔离。在IAM项目中的资源不能转移，只能删除后重建。 图1 IAM项目
创建请参见创建虚拟私有云和子网。 子网：选择已创建的子网，如何创建请参见为虚拟私有云创建新的子网。 请确保事件流集群配置的虚拟私有云、子网与Kafka或RocketMQ的源端实例、目标端实例配置的虚拟私有云、子网的网络互通，否则连通性测试不通过。 参数配置完成后，单击“立即购买”，完成集群创建。
已购买分布式消息服务RocketMQ版实例，实例中已创建Topic，且实例状态处于“运行中”。具体步骤，请参考购买实例。 已创建私网访问端点，其VPC及子网与RocketMQ实例相同。 已正确配置default安全组和RocketMQ实例所属的安全组规则，具体规则请参考创建事件源如何配置安全组。 创建RocketMQ事件源
从而通过身份认证。 AK(Access Key ID)：访问密钥ID。与私有访问密钥关联的唯一标识符；访问密钥ID和私有访问密钥一起使用，对请求进行加密签名。 SK(Secret Access Key)：与访问密钥ID结合使用的密钥，对请求进行加密签名，可标识发送方，并防止请求被修改。
源RocketMQ和目标RocketMQ实例的规格、Broker数量、存储空间需保持一致。 确保vpc、子网、RocketMQ等资源充足。 确保源端和目标端实例与用户创建事件流集群时选择的VPC网络互通。 创建VPC和子网的操作指导请参考创建虚拟私有云和子网。 操作步骤 登录事件网格控制台。 在左侧导
志，以便日后的审计和回溯。 日常操作 创建自定义事件源 事件通道 创建事件订阅 创建事件流 过滤规则参数说明 事件内容转换 网络管理 运维与监控 支持云审计的操作列表 查看云审计日志 事件监控 04 SDK 事件网格提供开源的CloudEvents SDK，并提供发布事件代码示例，帮助您轻松完成二次开发。
说明 实例 选择Kafka实例。 Topic 选择Topic。 消费组 输入消费组。 并发数 输入并发数，输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致，如果不一致可能会影响消息消费速率。当您选择Topic时，如果并发数为空会读取您选择的Topic的分区数作为并发数。
选择云服务事件源。 事件类型（可选） 选择事件网格预定义的事件类型。 过滤规则 输入事件过滤规则。 事件源产生的事件与过滤规则进行匹配，匹配成功后事件才会被路由到与过滤规则关联的事件目标。如果需要了解更多过滤规则的信息，请参考过滤规则参数说明和过滤规则示例。 图1 云服务事件源配置参数
选择云服务事件源。 事件类型（可选） 选择事件网格预定义的事件类型。 过滤规则 输入事件过滤规则。 事件源产生的事件与过滤规则进行匹配，匹配成功后事件才会被路由到与过滤规则关联的事件目标。如果需要了解更多过滤规则的信息，请参考过滤规则参数说明和过滤规则示例。 图3 云服务事件源配置参数
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
