检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置事件源。 单击“事件源”，参考图2，设置事件源参数。 选择提供方：选择“云服务” 事件源：选择“对象存储服务” 过滤规则：保存默认 图2 设置事件源参数 单击“确定”，完成事件源的配置。 配置事件目标。 单击“事件目标”，参考图3，设置事件目标参数。 选择提供方：选择“云服务”
生产顺序性和消费顺序性组合 生产顺序 消费顺序 顺序性效果 设置消息组，保证消息顺序发送。 顺序消费 按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。 设置消息组，保证消息顺序发送。 并发消费 并发消费，尽可能按时间顺序处理。 未设置消息组，消息乱序发送。 顺序消费 按队列存储粒度，严格顺序。
配置事件源 选择事件源提供方。 云服务：云服务事件源作为事件源提供方。 自定义：您自定义的事件源作为事件源提供方。 设置事件源参数。 当提供方为“云服务”时，设置如表1所示参数。 表1 云服务事件源参数说明 参数名称 说明 事件源 选择云服务事件源。 事件类型（可选） 选择事件网格预定义的事件类型。
创建函数”，具体详情请参见创建函数。 进入新建的函数详情页。 在“代码”页签，代码选择“上传自ZIP文件”，上传样例代码中的程序包。 在“设置 > 环境变量”页签，输入环境信息，完成后单击“保存” 表1 参数说明 参数 说明 obs_endpoint index.py文件中定义的
域。 在“Kafka专享版”页面，单击Kafka实例的名称“eg-kafka”，进入实例详情页面。 选择“消息查询”页签，在消息页签页面，设置查询的Topic名称“topic-eg”、分区以及查询方式。 单击“搜索”，查询消息。 单击“查看消息正文”，弹出“查看消息正文”对话框，查看消息的具体内容。
登录函数工作流控制台。 在左侧导航栏选择“函数 > 函数列表”，进入函数列表页面。 单击“创建函数”，进入“创建空白函数”页面。 参考图3，设置函数参数。关于函数参数的详细介绍，请参考创建函数。 函数类型：选择“事件函数” 区域：选择业务区域 函数名称：输入“test” 委托名称：选择“未使用任何委托”
事件网格如何收费？ 事件网格根据自定义（包含云服务租户侧事件产生 ）或第三方事件流入的事件数量进行计费，具体详情请参见价格计算器。 事件网格当前提供按需计费模式，这种购买方式比较灵活，按照实际使用量付费，没有最低消费。 华为云服务事件源自身产生发布的事件（任意事件状态变化 ）免费，事件消费免费。
您在欠费后需要及时充值，详细操作请参见账户充值。 相关事件不再使用，您可以将它们删除，避免不必要的扣费。 您可以在“费用中心 > 总览”页面设置“可用额度预警”功能。当可用额度、通用代金券和现金券的总额度低于预警阈值时，系统自动发送短信和邮件提醒。当产生欠费后，请您及时充值使可用额度大于0。
自定义事件目标中，地址存在拼写错误、非法域名、无效IP等情况。 检查域名或IP地址是否正确配置。IP地址不能配置为保留IP地址，例如：全0地址/环回地址/ECS链路地址169.254/受限广播地址等。
失败原因、失败详情和处理建议信息。用户可以根据失败信息和处理建议的指导，调整环境，以确保同步成功。 同步监控 全面可观测/可维护性，支持流控，同步情况，尽在掌握之中。 父主题： 专业版事件流
进入管理控制台页面，右上方选择“企业 > 项目管理”，进入企业项目管理页面。单击“创建企业项目”，完成企业项目的创建。 授权 通过为企业项目添加用户组，并设置策略，实现企业项目和用户组的关联。将用户加入到用户组，使用户具有用户组中的权限，从而精确地控制用户所能访问的项目，以及所能操作的资源。具体步骤如下：
目标是否已是连通状态，已配置的事件规则是否生效，事件是否成功发送到事件目标。 前提条件： 已创建自定义事件通道、已创建自定义应用事件源、已设置事件目标，并基于上述内容创建事件订阅。 登录事件网格控制台。 在左侧导航栏选择“事件通道”，进入“事件通道”页面。 单击“发布事件”，进入“发布事件”页面。
同结果，请严格按照需求选择消费方式。1、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：顺序消费，实际消息处理结果：按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：并发消费，实际消
完成后单击“确定”。 配置Kafka事件源。 单击“事件源”，右侧弹出“事件源”弹窗。 事件提供方选择“分布式消息服务 Kafka版”。 设置事件源参数。 图1 事件源-Kafka 表1 Kafka参数说明 参数名称 说明 实例 选择Kafka实例。 接入方式 选择“密文接入”或“明文接入”。
200 心跳成功 设置事件流状态为RUNNING，清除告警。 正常提示。 601 未知致命异常 设置事件流状态为ERROR，上报告警，自动重启事件流。 建议联系华为工程师处理。 602 网络异常 502 消费者不存在 401 目标端投递认证失败 主动刷新token，设置事件流状态为ERROR，自动重启事件流。
同结果，请严格按照需求选择消费方式。1、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：顺序消费，实际消息处理结果：按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：并发消费，实际消
同结果，请严格按照需求选择消费方式。1、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：顺序消费，实际消息处理结果：按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：并发消费，实际消
同结果，请严格按照需求选择消费方式。1、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：顺序消费，实际消息处理结果：按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：并发消费，实际消
buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据，同时重试配置不会发生作用（因为客户端不知道是否失败）回馈的offset会总是设置为-1。 acks=1：这意味着至少要等待leader已经成功将数据写入本地log，但是并没有等待所有follower是否成功写入。如果f
件目标是否已是连通状态，已配置的事件规则是否生效，事件是否成功发送到事件目标。 前提条件 已创建自定义事件通道 已创建自定义应用事件源 已设置事件目标，并基于上述内容创建事件订阅 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件通道”，进入“事件通道”页面。 单击“发布事件”，进入“发布事件”页面。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
