如需了解国际站更多云产品，请访问国际站。https://www.huaweicloud.com/intl/
不再显示此消息
如需了解国际站更多云产品，请访问国际站。https://www.huaweicloud.com/intl/
不再显示此消息
cluster_id=abc&limit=1000&offset=0 响应示例 状态码：200 请求成功 { "size" : 1, "total" : 1, "items" : [ { "cluster_id" : "fac59513-6c18-4266-bc81
否 String AccessKey secret_key 否 String SecretKey message_model 是 String 订阅方式 addr_type 是 String 接入点类型 addr 是 String 地址 sdk_url 是 String 依赖SDK
基于Serverless版事件流实现Kafka实例之间的数据同步 方案概述 实施及验证
创建用户并授权使用EG 如果您需要对您所拥有的EG服务进行精细的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），通过IAM，您可以： 根据企业的业务组织，在您的华为云账号中，给企业中不同职能部门的员工创建IAM用户，
RocketMQ采集函数错误码 错误码 错误码说明 运维说明 操作建议 200 心跳成功 设置事件流状态为RUNNING，清除告警。 正常提示。 601 未知致命异常 设置事件流状态为ERROR，上报告警，自动重启事件流。 建议联系华为工程师处理。 602 网络异常 502 消费者不存在
方案概述 事件流作为一种更为实时、轻量和高效的端到端的流式数据处理通道，对事件源产生的事件实时拉取、过滤及转换，并路由至事件目标。 源端分布式消息Kafka版生产的消息可以通过事件流这个通道被路由到目标端的分布式消息Kafka版，无需定义事件网格。详情请参见事件流概述。 本文介绍如何应用事件网格
实施及验证 约束与限制 事件目标kafka不支持自定义证书。 单消息需保持大小在2M以下。 源端配置操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”，右上角单击“创建Serverless版事件流”。 左上角单击，配置事件流名称和描述，完成后单击
参数 参数类型 描述 total Integer 总数 result Array of EventSubMetricsItem objects 指标数据列表 表5 EventSubMetricsItem 参数 参数类型 描述 fail_num Long 失败数 retry_success_num
基于Serverless版事件流实现RocketMQ推送事件至函数工作流服务 本文介绍如何通过事件网格服务的事件流功能将RocketMQ产生的事件推送至函数工作流服务。 前提条件 进行本实践操作需要提前完成的事项： 已开通事件网格服务并授权。 已创建虚拟私有云和子网。 已创建安全组
表16 SinkObsParameters 参数 参数类型 描述 access_key String AK secret_key String SK obs_bucket String 桶 obs_path String 转储目录 time_format String 时间目录格式
表14 SinkObsParameters 参数 参数类型 描述 access_key String AK secret_key String SK obs_bucket String 桶 obs_path String 转储目录 time_format String 时间目录格式
响应参数 状态码：200 表3 响应Header参数 参数 参数类型 描述 X-Request-Id String 请求ID 表4 响应Body参数 参数 参数类型 描述 cluster_id String 专业版事件流集群ID job_id String 专业版事件流作业ID name
如果您给用户授予EG FullAccess的系统策略，但不希望用户拥有EG FullAccess中定义的删除事件源权限，您可以创建一条拒绝删除事件源的自定义策略，然后同时将EG FullAccess和拒绝策略授予用户，根据Deny优先原则，则用户可以对EG执行除了删除事件源外的所有操作
总数 result Array of EventPubMetricsItem objects 指标列表 表5 EventPubMetricsItem 参数 参数类型 描述 event_size Long 事件大小 timestamp Long 时间戳 num Long 调用数 success_num
MRS:Cluster:OperationAction MapReduce服务 MRS OPENAPI 3.0 MRS集群活动事件，例如集群创建和删除等。
单位：个 ≥ 0 counts 事件通道 1分钟 success_num 成功数量 该指标用于统计事件接入的调用成功数量。 单位：个 ≥ 0 counts 事件通道 1分钟 fail_num 失败数量 该指标用于统计事件接入的调用失败数量。
Access Key（启用鉴权认证） 请输入Access Key。 Secret Key（启用鉴权认证） 请输入Secret Key。 订阅方式 请选择集群或广播。 接入点类型 请选择公网或私网。 地址 请输入地址。 客户端SDK 请输入客户端SDK上传到OBS的地址。
DNS ReadOnlyAccess 目标连接功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。
监控指标 表1 监控指标说明 指标ID 指标名称 指标含义 取值范围 测量对象 监控周期（原始值） pub_num 接入事件数量 该指标为单位时间通道接入事件数量 ≥ 0 事件通道 1分钟 pub_success_num 接入事件成功数量 该指标为单位时间通道接入事件成功数量 ≥
监控指标 表1 监控指标说明 指标ID 指标名称 指标含义 取值范围 测量对象 监控周期（原始值） streaming_process_num 处理事件数量 该指标为单位时间处理事件数量 ≥ 0 事件流 1分钟 streaming_success_num 处理成功事件数量 该指标为单位时间处理成功事件数量
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
您即将访问非华为云网站，请注意账号财产安全
