检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
并发数 输入并发数,输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致,如果不一致可能会影响消息消费速率。当您选择Topic时,如果并发数为空会读取您选择的Topic的分区数作为并发数。 消费点位 选择消费点位。 最新点位:将会从消息队列的最新消息开始消费。
最小值:20 最大值:64 缺省值:20 consumer_batch_max_size 否 Integer 批量消费最大消息数 最小值:1 最大值:1024 缺省值:20 consumer_max_wait 否 Integer 批量消费最大等待时长,单位:秒 最小值:0 最大值:
Array of EventPubMetricsItem objects 指标列表 数组长度:0 - 100 表5 EventPubMetricsItem 参数 参数类型 描述 event_size Long 事件大小 timestamp Long 时间戳 num Long 调用数
retry_success_num Long 重试成功数 retry_fail_num Long 重试失败数 retry_times Integer 重试数 timestamp Long 时间戳 num Long 调用数 success_num Long 调用成功数 process_time
String 错误信息 最小长度:1 最大长度:128 表8 flavor 参数 参数类型 描述 name String 规格名称 concurrency_type String 并发规格类型 枚举值: shared exclusive concurrency Integer 并发数
最小值:20 最大值:64 缺省值:20 consumer_batch_max_size Integer 批量消费最大消息数 最小值:1 最大值:1024 缺省值:20 consumer_max_wait Integer 批量消费最大等待时长,单位:秒 最小值:0 最大值:450
最小值:20 最大值:64 缺省值:20 consumer_batch_max_size Integer 批量消费最大消息数 最小值:1 最大值:1024 缺省值:20 consumer_max_wait Integer 批量消费最大等待时长,单位:秒 最小值:0 最大值:450
并发数 输入并发数,输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致,如果不一致可能会影响消息消费速率。当您选择Topic时,如果并发数为空会读取您选择的Topic的分区数作为并发数。 消费点位 选择消费点位。 最新点位:将会从消息队列的最新消息开始消费。
10 ECU支持1~10个并发作业数,10 ECU Kafka最多支持40万QPS,RocketMQ支持3万QPS,DCS支持10万QPS。 网络配置。 虚拟私有云:选择已创建的虚拟私有云,如何创建请参见创建虚拟私有云和子网。
消费线程数 请输入20到64之间的整数。 批量消费最大消息数 请输入1到32之间的整数。 单击“下一步”,进入规则配置页面,规则配置可参考过滤规则参数说明。 图2 规则配置 单击“下一步”完成规则配置,您可以参考路由到函数工作流,继续配置事件流的事件目标。
最小值:20 最大值:64 缺省值:20 consumer_batch_max_size 否 Integer 批量消费最大消息数 最小值:1 最大值:1024 缺省值:20 consumer_max_wait 否 Integer 批量消费最大等待时长,单位:秒 最小值:0 最大值:
消费线程数 请输入20到64之间的整数。 批量消费最大消息数 请输入1到32之间的整数。 批量消费最大等待时长(秒) 请输入0到450之间的整数。 单击“下一步”,进入规则配置页面,规则配置可参考过滤规则参数说明。
消费线程数 请输入20到64之间的整数。 批量消费最大消息数 请输入1到32之间的整数。 最大重试次数 请输入最大重试次数。 设置-1表示无限重试,0表示不重试。 如果RockrtMQ版本为4.x版本,则默认允许每条消息最多重试16次,每次重试的时间间隔如表2所示。
String 错误信息 最小长度:1 最大长度:128 表7 flavor 参数 参数类型 描述 name String 规格名称 concurrency_type String 并发规格类型 枚举值: shared exclusive concurrency Integer 并发数
队列数 创建Topic时设置的队列个数。 待同步数 当前Topic队列数中未同步的消息数量。 父主题: 创建专业版事件流作业
String 错误信息 最小长度:1 最大长度:128 表7 flavor 参数 参数类型 描述 name String 规格名称 concurrency_type String 并发规格类型 枚举值: shared exclusive concurrency Integer 并发数
分区数 创建Topic时设置的分区数,分区数越大消费的并发度越大。 待同步数 当前Topic分区数中未同步的消息数量。 同步速率:当前作业同步消息时的速率,单击“限流”可跳转至源端Kafka实例的“流控列表”页面,用户可通过配置流控进而实现限流目的。
String 错误信息 最小长度:1 最大长度:128 表5 flavor 参数 参数类型 描述 name String 规格名称 concurrency_type String 并发规格类型 枚举值: shared exclusive concurrency Integer 并发数