检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
的源、package、函数名是否与预期相符。 事件目标的规则配置错误。 在事件订阅中配置事件目标时，检查选择的转换类型是否与预期相符。 自定义事件目标中，地址存在拼写错误、非法域名、无效IP等情况。 检查域名或IP地址是否正确配置。IP地址不能配置为保留IP地址，例如：全0地址/环回地址/ECS链路地址169
接公网webhook，也可以通过对应虚拟私有云和子网的目标连接来连接私网webhook。 公测 -- 2 访问端点 访问端点用于用户推送自定义事件，包括固定域名的公网访问端点和用户创建的私网访问端点。 公测 -- 2022年5月 序号 功能名称 功能描述 阶段 相关文档 1 事件网格
请选择是否开启ACL访问控制。 说明： 当开启ACL访问控制时，需要配置用户名及密钥。 tag 请输入tag。 消费点位 请选择最早、最新或自定义。 说明： 当消费点位选择自定义时，需要配置日期时间。 消费超时时间（毫秒） 请输入1000到900000之间的整数。 消息类型 默认为普通消息。 消费线程数
法律或其他要求。 可用区：一个可用区是一个或多个物理数据中心的集合，有独立的风火水电，AZ内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Region中的多个AZ间通过高速光纤相连，以满足用户跨AZ构建高可用性系统的需求。 项目 区域默认对应一个项目，这个项目由系统预置，用
状态码： 200 表1 响应Body参数 参数 参数类型 描述 versions Array of versions objects 版本定义 表2 versions 参数 参数类型 描述 id String 版本号，如v1 links Array of links objects
String 事件模型兼容性 枚举值： NONE provider_type String 提供方类型，OFFICIAL：官方事件源；CUSTOM：自定义事件源 枚举值： OFFICIAL CUSTOM format String 事件模型格式 number_of_versions Integer
未满足前提条件，服务器未满足请求者在请求中设置的其中一个前提条件。 413 Request Entity Too Large 由于请求的实体过大，服务器无法处理，因此拒绝请求。为防止客户端的连续请求，服务器可能会关闭连接。如果只是服务器暂时无法处理，则会包含一个Retry-After的响应信息。 414
如果源端kafka和目标端kafka在不同vpc里，但是他们的broker地址存在重叠，这种情况任务也会失败，规避方式是让用户用一个新的vpc打通其中一个kafka的网络，保障源端和目标端的地址不重叠。 创建任务成功后，会生成mm2开头的Topic，此为运行任务资源所需，请勿删除，若删除此任务后，则Topic可删除。
”。 在桶列表单击已创建的桶“eg-obs”，进入“对象”页面。 进入待上传的文件夹，单击“上传对象”，系统弹出“上传对象”对话框。 上传一个本地已准备好的文件，单击“上传”。 更多上传对象文件的方法请参考上传对象。 图1 上传对象 父主题： 实施步骤
String 事件源描述 provider_type String 事件源提供方类型，OFFICIAL：官方云服务事件源；CUSTOM：用户创建的自定义事件源；PARTNER：伙伴事件源 枚举值： OFFICIAL CUSTOM PARTNER event_types Array of event_types
说明： 目前只能选择与队列类型匹配的目标连接。 Topic 选择Topic。 说明： 如果事件目标与死信队列使用同一个Topic，EG将无法区分事件成功与失败，不推荐您配置同一个Topic。 单击“确定”，完成死信配置。 处理死信队列数据 当数据发送到死信队列后，您可以参考以下方法，来处理死信数据。
00，输入值范围1~10000。 开启批量推送可见，输入批量推送间隔，默认值1，输入值范围0~15，单位：秒。 事件目标kafka不支持自定义证书。 表3 批量推送示例 批量推送条数 推送间隔 实际发送效果 100条 1s 每隔1s批量推送100条消息 200条 5s 每隔5s批量推送500条消息
在实例“基本信息>连接信息”页面，单击SSL证书旁的“下载”。 SSL证书将会下载到本地电脑，名字为“kafka-certs.zip”的文件。 参考创建桶，创建一个OBS桶，桶的区域与Kafka实例区域保持一致，其“桶策略”需为“公共读”或“公共读写”。 最新版的事件流支持私有桶获取证书。 参考上传文
默认为“Kafka实例”。 说明： 配置类型根据实例类型变更。 实例别名 请输入实例别名。 说明： 用于标识源端和目标端实例，建议同一个源端或目标端实例只设置一个别名。 区域 请选择资源所在区域。 项目 请选择项目。 Kafka实例 请选择Kafka实例。 接入方式 支持“明文接入”或“密文接入”。
subscription status 启动中的订阅不能编辑 请稍后重试 400 EG.00513003 invalid target address 自定义事件目标url参数错误 请检查事件目标url参数 400 EG.00513004 invalid filter parameters 事件源过滤规则配置参数错误
description String 通道描述 provider_type String 通道提供方类型，OFFICIAL：官方事件通道；CUSTOM：自定义事件通道；PARTNER：伙伴事件通道 枚举值： OFFICIAL CUSTOM PARTNER created_time String 创建UTC时间
created_time String 创建时间 updated_time String 更新时间 definition String 事件模型内容定义 状态码： 400 表4 响应Body参数 参数 参数类型 描述 error_code String 错误码 最小长度：1 最大长度：128
FunctionGraph（函数计算）参数说明 参数名称 说明 函数 选择需要触发的函数。如果还未创建函数，请先创建函数。 版本/别名 配置版本/别名，当选择其一时，则另外一个参数无需配置。 版本 选择函数的版本。当前默认选择“latest”。 别名 选择函数别名。 执行方式 默认“同步”。 委托 选择委托。如无
而此时leader又无法提供服务，则消息会丢失。 acks=all：这意味着leader需要等待ISR中所有备份都成功写入日志，只有任何一个备份存活，数据都不会丢失。min.insync.replicas指定必须确认写入才能被认为成功的副本的最小数量。 缺省值：1 枚举值： 0
] }] } } 无 空值匹配 检查某个字段的值是否为null或未定义。如下表所示，过滤规则只匹配“data”下“size”和“age”字段取值为null或未定义的事件。 从事件源接收的事件 过滤规则 过滤后的事件 { "events":[{ "id":
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
