上云无忧 > 文档中心 > 腾讯云消息队列 CKafka - 数据上报相关问题
消息队列 CKafka
腾讯云消息队列 CKafka - 数据上报相关问题

文档简介:
如何确认数据上报成功? 当请求的云 API 接口返回 MessageId 字段时,即代表数据已上报成功。参见云 API 调用返回 云 API 返回结果。
*此产品及展示信息均由腾讯云官方提供。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

如何确认数据上报成功?

当请求的云 API 接口返回 MessageId 字段时,即代表数据已上报成功。参见云 API 调用返回 云 API 返回结果

上报数据,出现错误怎么处理?

数据上报过程中,常见的云 API 错误返回结果如下:
		
{
"Response": {
"Error": {
"Message": "TopicAuthorizationException: Not authorized to access topics: [xxxxx]",
"Code": "FailedOperation"
},
"RequestId": "xxxx9bef-52fd-4242-bdc0-8cf5e55xxxxxx"
}
}
1. 根据报错信息可检查 Topic 是否设置了ACL 权限(目前 HTTP 数据上报暂不支持 ACL 设置)需要关闭前 Topic 所设置的 ACL。
		
{
"Response": {
"Error": {
"Message": "task status suspended [datahub-lz7xxxxv]",
"Code": "FailedOperation.ResourceTaskPaused"
},
"RequestId": "xxxxifef-942fd-4242-bdc0-z3f5e55xxxxxx"
}
}
2. 根据错误消息内容看到当前任务状态处于暂停状态,恢复任务状态至运行中即可。
		
{
"Response": {
"Error": {
"Message": "limit exceeded dataHubId [datahub-nyxxxxiy]",
"Code": "RequestLimitExceeded"
},
"RequestId": "xxxxqsnrf-942fd-4242-nsdc0-z3f5e55xxxxxx"
}
}
3. 每秒的请求数量到接口达上限。可根据业务提单调整当前的 QPS 限制。
4. 其他错误信息也可反馈完整的错误信息,可以 联系我们 处理。

数据上报配额是多少,如何提升配额?

数据上报是通过 HTTP 协议接入数据,HTTP 的接口的 QPS 限制默认是2000。当超时2000时,就会报 request limit 的限制。
如果需要更高的 QPS,可以 联系我们 处理,提升单个任务 ID 的 QPS 限制。
相似文档
  • 数据处理过程中,因格式问题处理失败的数据会怎么处理? 数据处理过程中,因格式问题处理失败或不满足过滤器规则的数据会流向“失败处理”策略。
  • 如何知道数据转储是否有堆积? CKafka 数据转储,即 Kafka 的数据流出转储到其他源中,常见的例如 kafka to es,kafka to clickhouse 等等。
  • MySQL 异常处理: 配置和启动错误: 以下几种情况会导致连接器启动失败,并在日志中报告错误或异常,然后停止运行: connector 的配置无效。 connector 根据相关配置参数无法连接上 MySQL 服务器。 connector 在重启后尝试从故障点恢复,但MySQL 的 binlog 被清理无相应历史记录。
  • 为使用腾讯云消息队列 CKafka 服务(以下简称“本服务”),您应当阅读并遵守《消息队列 CKafka 服务等级协议》(以下简称“本协议”),以及《腾讯云服务协议》。本协议包含本服务的术语和定义、服务可用性/服务成功率等级指标、赔偿方案、免责条款等相关内容。请您务必审慎阅读、充分理解各条款内容,限制、免责条款或者其他涉及您重大权益的条款可能会以加粗、加下划线等形式提示您重点注意。
  • 消息队列 RocketMQ 版(TDMQ for RocketMQ,简称 TDMQ RocketMQ 版)是一款腾讯自主研发的消息队列服务,兼容 Apache RocketMQ 的各个组件与概念,支持 RocketMQ 4.6.1及以上版本的客户端零改造接入,同时具备计算存储分离、灵活扩缩容的底层优势。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部