检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
支持地域 支持在分布式消息服务Kafka版之间创建事件流的地域有：华东-上海一、华东-上海二、华北-北京四、华南-广州、亚太-新加坡、拉美-墨西哥城二。 父主题： 基于Serverless版事件流实现Kafka实例之间的数据同步
背景信息 事件流作为一种更为实时、轻量和高效的端到端的流式数据处理通道，对事件源产生的事件实时拉取、过滤及转换，并路由至事件目标。源端分布式消息Kafka版生产的消息可以通过事件流这个通道被路由到目标端的分布式消息Kafka版，无需定义事件网格。详情请参见事件流概述。 父主题：
输入并发数，输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致，如果不一致可能会影响消息消费速率。当您选择Topic时，如果并发数为空会读取您选择的Topic的分区数作为并发数。 消费点位 选择消费点位。 最新点位：将会从消息队列的最新消息开始消费。 最早点位：将会从消息队列的最早消息开始消费。
前提条件 已开通事件网格服务并授权。 已购买Kafka实例。 已创建分布式消息Kafka版类型的目标连接，具体方式请参考目标连接。 单条消息不超过256KB。 公测期间无商用SLA承诺。 当前暂不支持跨Region、Kafka-OBS（规划中）。 云上云下、跨云厂商需用户侧拉专线。
文件包含了本次查询结果的所有事件，且最多导出5000条信息。 单击按钮，可以获取到事件操作记录的最新信息。 在需要查看的事件左侧，单击展开该记录的详细信息。 在需要查看的记录右侧，单击“查看事件”，会弹出一个窗口显示该操作事件结构的详细信息。 关于事件结构的关键字段详解，请参见《
购买RCU时套餐包，当月未使用完的RCU时下个月是否可以继续使用？ 不可以，上个生效月RCU时余量不可以转结到下个生效月。 父主题： 计费FAQ
8 请下载1.4.0版本的 Java SDK 将jar包打包成zip文件 参考创建桶，创建一个OBS桶，桶的区域与EG服务的区域保持一致，其“桶策略”需为“公共读”或“公共读写”。 参考上传文件，在桶的根目录下上传打包的ZIP文件。 在OBS中单击上传的对象，可以复制链接地址，此地址即为客户端SDK地址。
在函数服务的监控中查看代码执行详情 在“函数列表”中找到进行数据同步的函数： 图1 函数列表 单击监控中对应的请求查看代码日志： 图2 代码日志 父主题： 实施步骤
相关概念 事件 状态发生改变的数据记录。 事件源 事件的来源，负责生产事件。 事件目标 事件的处理终端，负责消费事件。 事件通道 事件的中转站，负责接收来自事件源的事件。 事件规则 事件发送到事件网格后，会根据事件规则进行过滤，满足规则的事件才会被路由发送到对应的事件目标。
如果需要修改自定义事件源的描述信息，单击待修改事件源后的“编辑”，在弹出的对话框中编辑描述及相关参数信息。 如果需要查看自定义事件源的信息，单击待查看信息的事件源名称，在弹出的对话框中查看自定义事件源信息。 如果发送事件界面配置的事件源为新事件源（事件源列表查询不到），发送事件后，无法在CES服务监控里查询到监控信息。
允许删除事件源的权限策略，控制他们对事件网格资源的使用范围。 如果华为云账号已经能满足您的要求，不需要创建独立的IAM用户进行权限管理，您可以跳过本章节，不影响您使用事件网格的其它功能。 IAM是华为云提供权限管理的基础服务，无需付费即可使用，您只需要为您账号中的资源进行付费。请参见IAM产品介绍。
事件通道负责接收来自事件源的事件。 事件网格支持的事件通道如下： 云服务事件通道：由事件网格自动创建、且不可修改的一条默认的云服务事件通道，用于接收云服务事件源产生的事件。云服务事件源产生的事件只能发布到云服务事件通道。 自定义事件通道：您自行创建的事件通道，用于接收自定义事件源产生的事件。 父主题：
事件路由基于SmartConnect实现能力同步数据的同步。 约束与限制 事件路由公测期间免费。 如果源端kafka和目标端kafka在不同vpc里，但是他们的broker地址存在重叠，这种情况任务也会失败，规避方式是让用户用一个新的vpc打通其中一个kafka的网络，保障源端和目标端的地址不重叠。 事件路由
触发器类型：选择“分布式消息服务（Kafka）”。 实例：选择与死信队列相同的Kafka实例。 主题：选择与死信队列相同的Topic。 批处理大小：每次从Topic消费的消息数量，建议设置为10。 用户名：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的用户名。 密码：Kafka实例开启SSL时需
事件目标 事件目标是事件的处理终端，负责消费事件。 事件网格支持的事件目标如下： 云服务事件目标：已对接事件网格的华为云服务。 自定义事件目标：您自定义的处理事件的服务。
根据企业用户的职能，设置不同的访问权限，以达到用户之间的权限隔离。 将EG资源委托给更专业、高效的其他华为云账号或者云服务，这些账号或者云服务可以根据权限进行代运维。 如果华为云账号已经能满足您的要求，不需要创建独立的IAM用户，您可以跳过本章节，不影响您使用EG服务的其它功能。
Serverless版事件流概述 事件流对事件源产生的事件实时拉取、过滤及转换，并路由至事件目标，是一种更为实时、轻量和高效的端到端的流式数据处理场景。 图1 事件流示意图 EG事件流目前处于公测阶段，欢迎您试用和体验相关的功能。 父主题： 事件流
过滤规则参数说明 事件源产生的事件与过滤规则进行匹配，匹配成功后事件才会被路由到与过滤规则关联的事件目标。过滤规则必须和匹配的事件具有相同的结构。 本章节介绍过滤规则和事件匹配时的规则，以及构成过滤规则的参数：运算操作符、条件表达式和匹配字段。 匹配规则 过滤规则和事件匹配时，需要遵循以下规则：
事件目标为分布式消息服务Kafka版。 创建一个目标连接，类型为“分布式消息服务 Kafka版”。 1 00.00 本文提供的成本预估费用仅供参考，资源的实际费用以华为云管理控制台显示为准。 父主题： 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
SDK概述 本文主要介绍事件网格提供的开源CloudEvents SDK，以简化您的开发工作。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
