tencent cloud
腾讯云
最新优惠
产品
解决方案
价格中心
合作伙伴网络
云市场
探索更多
Prev
Next
腾讯云
注册
登录
最新优惠
产品
解决方案
价格中心
合作伙伴网络
云市场
探索更多
语言
International
Intl - English
Intl - 한국어
Intl - 日本語
Intl - 简体中文
Intl - Português
Intl - Bahasa Indonesia
中国站
简体中文
联系我们
控制台
文档
搜索
文档反馈
请输入关键字
Recent Pages
Cloud Virtual Machine
Auto Scaling
CVM Dedicated Host
Batch Compute
Cloud File Storage
文档
消息队列 CKafka 版
动态与公告
新功能发布记录
Broker 版本升级记录
连接器发布记录
Datahub 新功能发布记录
产品简介
产品概述
产品优势
应用场景
技术原理
开源对比
使用限制
地域和可用区
购买指南
产品规格
专业版 - 弹性存储
计费概述
计费概述
按量计费
包年包月
欠费说明
退费说明
快速入门
入门流程指引
获取访问授权
子账号获取访问授权
授予子账号操作级权限
授予子账号资源级权限
授予子账号标签级权限
VPC 网络接入
步骤1:创建实例
步骤2:创建 Topic
步骤3:添加 VPC 网络路由
步骤4:收发消息
使用 SDK 收发消息(推荐)
运行 Kafka 客户端(可选)
公网域名接入
步骤1:创建实例
步骤2:添加公网路由
步骤3:创建 Topic
步骤4:配置 ACL 策略
步骤5:收发消息
使用 SDK 收发消息(推荐)
运行 Kafka 客户端(可选)
操作指南
实例管理
创建实例
批量连续命名或指定模式串命名
查看实例
升配实例
降配实例
销毁/退还实例
按量计费实例转包年包月
升级实例版本
添加路由策略
公网带宽管理
接入外部监控 Prometheus
迁移可用区
设置系统维护时间
配置消息大小
Topic 管理
实例 Topic
创建 Topic
查看 Topic
删除 Topic
发送消息
设置 Topic 限流规则
弹性 Topic
Topic 管理
订阅管理
Consumer Group
概述
创建 Consumer Group
查询 Consumer Group
删除 Consumer Group
设置 Offset
自动重置 offset
监控告警
查看监控信息
查询高级监控(专业版)
配置告警
告警配置建议
查看高级运维特性(专业版)
智能运维
弹性伸缩
磁盘水位处理
分区动态处理
弹性宽带
权限管理
配置 ACL 策略
访问管理 CAM
标签管理
标签概述
使用标签
编辑标签
查询消息
事件中心
迁移上云
迁移方案概述
步骤1:购买云上实例
步骤2:迁移 Topic 上云
步骤3:迁移数据上云
方案1:单写双消费迁移
方案2:单写单消费迁移
方案3:使用 Mirrormaker 迁移
方案4:迁移未消费数据
数据压缩
CKafka 连接器
连接器简介
连接器概述
连接器优势
应用场景
技术原理
使用限制
连接管理开放网段
连接管理
任务管理
新建数据接入任务
HTTP 上报
对象存储 COS
数据传输服务 DTS
MongoDB
新建数据流出任务
数据目标
数据仓库(ClickHouse)
日志服务 (CLS)
对象存储(COS)
Elasticsearch Service
TDSQL-C PostgreSQL
分布式数据仓库(TDW)
简单数据处理
数据转换
过滤器规则说明
管理任务
Schema 管理
事件中心
实践教程
CKafka 客户端实践教程
生产消费实践教程
Confluent Go SDK
Sarama Go
Java SDK
Kafka Python SDK
ibrdkafka SDK
tRpc Go SDK
连接器实践教程
HTTP 上报
HTTP 协议接入 Kafka
统一数据上报
数据库变更订阅查询
Mongo Stream 数据变更记录分析
数据简单清洗
Flink 接入 CKafka
Schema Registry 接入 CKafka
Spark Streaming 接入 CKafka
Flume 接入 CKafka
Kafka Connect 接入 CKafka
Storm 接入 CKafka
Logstash 接入 CKafka
Filebeat 接入 CKafka
跨可用区部署
日志接入
日志服务 CLS
替换支撑路由(旧)
高 CPU 场景下集群带宽实践教程
集群容量规划实践教程
故障处理
Topic 相关故障
Topic 创建失败
Topic 无监控数据
Topic 配置 ACL 策略后导致其他产品联动能力失效
分区的监控查看消息堆积数量一直存在
Consumer Group 相关故障
Consumer Group 列表详情缺失
Consumer Group 持续出现 PreparingRebalance 状态
客户端相关故障
客户端常见报错与解决方案
客户端生产消息进入到阻塞状态
客户端消费不到消息
Sarama 客户端异常
消息相关故障
消费数据异常
过期消息没有被及时删除
消费速度缓慢
出现消息堆积的警告
生产一段时间后发现持续性错误
API 文档
History
Introduction
API Category
Making API Requests
Request Structure
Common Params
Signature v3
Signature
Responses
DataHub APIs
DescribeDatahubTopics
SendMessage
ACL APIs
BatchCreateAcl
CreateAcl
CreateAclRule
CreateUser
DeleteAcl
DeleteUser
DescribeACL
DescribeAclRule
DescribeUser
ModifyAclRule
ModifyPassword
Topic APIs
BatchModifyGroupOffsets
BatchModifyTopicAttributes
CreateConsumer
CreateDatahubTopic
CreatePartition
CreateTopic
CreateTopicIpWhiteList
DeleteTopic
DeleteTopicIpWhiteList
DescribeDatahubTopic
DescribeTopic
DescribeTopicAttributes
DescribeTopicDetail
DescribeTopicProduceConnection
DescribeTopicSubscribeGroup
FetchMessageByOffset
FetchMessageListByOffset
ModifyDatahubTopic
ModifyTopicAttributes
DescribeTopicSyncReplica
Instance APIs
CreatePostPaidInstance
CreateInstancePost
DescribeInstances
DeleteInstancePre
DescribeGroupInfo
DescribeGroupOffsets
DescribeInstanceAttributes
DescribeInstancesDetail
InquireCkafkaPrice
ModifyGroupOffsets
ModifyInstanceAttributes
ModifyInstancePre
Route APIs
DescribeTaskStatus
DeleteRoute
DescribeRoute
Other APIs
DeleteRouteTriggerTime
DescribeAppInfo
DescribeCkafkaZone
DescribeConsumerGroup
DescribeGroup
DescribeRegion
Data Types
Error Codes
SDK 文档
SDK 概览
Java SDK
VPC 网络接入
VPC 网络 SASL_SCRAM 方式接入
公网 SASL_PLAINTEXT 方式接入
SASL_SSL 方式接入
Python SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
公网 SASL_SSL 方式接入
Go SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
PHP SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
C++ SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
Node.js SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
连接器相关 SDK
数据上报 SDK
弹性 Topic 收发消息 SDK
Java SDK
Python SDK
Go SDK
PHP SDK
C++ SDK
Node.js SDK
Filebeats 接入 CKafka
Logstash 接入 CKafka
通用参考
对 CKafka 进行生产和消费压力测试
常见参数配置说明
接入低版本自建 Kafka
CKafka 版本选择建议
CKafka 数据可靠性说明
连接器
数据库变更订阅
MongoDB 数据订阅
MySQL 数据订阅
PostgreSQL 数据订阅
MySQL 订阅消息官方格式说明
MySQL 订阅消息 canal 格式说明
连接器订阅 PostgreSQL 时用户权限设置参考
数据处理
数据处理规则说明
正则提取
JsonPath 说明
自建集群接入说明(CLB 方式)
连接器访问 CLS、COS 等服务的授权说明
什么是信令表
常见问题
实例问题
Topic 问题
Consumer Group 问题
客户端问题
网络问题
限流问题
监控问题
消息问题
概念问题
连接器问题
任务相关问题
数据上报相关问题
数据处理相关问题
数据转存相关问题
数据订阅相关问题
服务等级协议
联系我们
词汇表
文档
动态与公告
新功能发布记录
Broker 版本升级记录
连接器发布记录
Datahub 新功能发布记录
产品简介
产品概述
产品优势
应用场景
技术原理
开源对比
使用限制
地域和可用区
购买指南
产品规格
专业版 - 弹性存储
计费概述
计费概述
按量计费
包年包月
欠费说明
退费说明
快速入门
入门流程指引
获取访问授权
子账号获取访问授权
授予子账号操作级权限
授予子账号资源级权限
授予子账号标签级权限
VPC 网络接入
步骤1:创建实例
步骤2:创建 Topic
步骤3:添加 VPC 网络路由
步骤4:收发消息
使用 SDK 收发消息(推荐)
运行 Kafka 客户端(可选)
公网域名接入
步骤1:创建实例
步骤2:添加公网路由
步骤3:创建 Topic
步骤4:配置 ACL 策略
步骤5:收发消息
使用 SDK 收发消息(推荐)
运行 Kafka 客户端(可选)
操作指南
实例管理
创建实例
批量连续命名或指定模式串命名
查看实例
升配实例
降配实例
销毁/退还实例
按量计费实例转包年包月
升级实例版本
添加路由策略
公网带宽管理
接入外部监控 Prometheus
迁移可用区
设置系统维护时间
配置消息大小
Topic 管理
实例 Topic
创建 Topic
查看 Topic
删除 Topic
发送消息
设置 Topic 限流规则
弹性 Topic
Topic 管理
订阅管理
Consumer Group
概述
创建 Consumer Group
查询 Consumer Group
删除 Consumer Group
设置 Offset
自动重置 offset
监控告警
查看监控信息
查询高级监控(专业版)
配置告警
告警配置建议
查看高级运维特性(专业版)
智能运维
弹性伸缩
磁盘水位处理
分区动态处理
弹性宽带
权限管理
配置 ACL 策略
访问管理 CAM
标签管理
标签概述
使用标签
编辑标签
查询消息
事件中心
迁移上云
迁移方案概述
步骤1:购买云上实例
步骤2:迁移 Topic 上云
步骤3:迁移数据上云
方案1:单写双消费迁移
方案2:单写单消费迁移
方案3:使用 Mirrormaker 迁移
方案4:迁移未消费数据
数据压缩
CKafka 连接器
连接器简介
连接器概述
连接器优势
应用场景
技术原理
使用限制
连接管理开放网段
连接管理
任务管理
新建数据接入任务
HTTP 上报
对象存储 COS
数据传输服务 DTS
MongoDB
新建数据流出任务
数据目标
数据仓库(ClickHouse)
日志服务 (CLS)
对象存储(COS)
Elasticsearch Service
TDSQL-C PostgreSQL
分布式数据仓库(TDW)
简单数据处理
数据转换
过滤器规则说明
管理任务
Schema 管理
事件中心
实践教程
CKafka 客户端实践教程
生产消费实践教程
Confluent Go SDK
Sarama Go
Java SDK
Kafka Python SDK
ibrdkafka SDK
tRpc Go SDK
连接器实践教程
HTTP 上报
HTTP 协议接入 Kafka
统一数据上报
数据库变更订阅查询
Mongo Stream 数据变更记录分析
数据简单清洗
Flink 接入 CKafka
Schema Registry 接入 CKafka
Spark Streaming 接入 CKafka
Flume 接入 CKafka
Kafka Connect 接入 CKafka
Storm 接入 CKafka
Logstash 接入 CKafka
Filebeat 接入 CKafka
跨可用区部署
日志接入
日志服务 CLS
替换支撑路由(旧)
高 CPU 场景下集群带宽实践教程
集群容量规划实践教程
故障处理
Topic 相关故障
Topic 创建失败
Topic 无监控数据
Topic 配置 ACL 策略后导致其他产品联动能力失效
分区的监控查看消息堆积数量一直存在
Consumer Group 相关故障
Consumer Group 列表详情缺失
Consumer Group 持续出现 PreparingRebalance 状态
客户端相关故障
客户端常见报错与解决方案
客户端生产消息进入到阻塞状态
客户端消费不到消息
Sarama 客户端异常
消息相关故障
消费数据异常
过期消息没有被及时删除
消费速度缓慢
出现消息堆积的警告
生产一段时间后发现持续性错误
API 文档
History
Introduction
API Category
Making API Requests
Request Structure
Common Params
Signature v3
Signature
Responses
DataHub APIs
DescribeDatahubTopics
SendMessage
ACL APIs
BatchCreateAcl
CreateAcl
CreateAclRule
CreateUser
DeleteAcl
DeleteUser
DescribeACL
DescribeAclRule
DescribeUser
ModifyAclRule
ModifyPassword
Topic APIs
BatchModifyGroupOffsets
BatchModifyTopicAttributes
CreateConsumer
CreateDatahubTopic
CreatePartition
CreateTopic
CreateTopicIpWhiteList
DeleteTopic
DeleteTopicIpWhiteList
DescribeDatahubTopic
DescribeTopic
DescribeTopicAttributes
DescribeTopicDetail
DescribeTopicProduceConnection
DescribeTopicSubscribeGroup
FetchMessageByOffset
FetchMessageListByOffset
ModifyDatahubTopic
ModifyTopicAttributes
DescribeTopicSyncReplica
Instance APIs
CreatePostPaidInstance
CreateInstancePost
DescribeInstances
DeleteInstancePre
DescribeGroupInfo
DescribeGroupOffsets
DescribeInstanceAttributes
DescribeInstancesDetail
InquireCkafkaPrice
ModifyGroupOffsets
ModifyInstanceAttributes
ModifyInstancePre
Route APIs
DescribeTaskStatus
DeleteRoute
DescribeRoute
Other APIs
DeleteRouteTriggerTime
DescribeAppInfo
DescribeCkafkaZone
DescribeConsumerGroup
DescribeGroup
DescribeRegion
Data Types
Error Codes
SDK 文档
SDK 概览
Java SDK
VPC 网络接入
VPC 网络 SASL_SCRAM 方式接入
公网 SASL_PLAINTEXT 方式接入
SASL_SSL 方式接入
Python SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
公网 SASL_SSL 方式接入
Go SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
PHP SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
C++ SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
Node.js SDK
VPC 网络接入
公网 SASL_PLAINTEXT 方式接入
连接器相关 SDK
数据上报 SDK
弹性 Topic 收发消息 SDK
Java SDK
Python SDK
Go SDK
PHP SDK
C++ SDK
Node.js SDK
Filebeats 接入 CKafka
Logstash 接入 CKafka
通用参考
对 CKafka 进行生产和消费压力测试
常见参数配置说明
接入低版本自建 Kafka
CKafka 版本选择建议
CKafka 数据可靠性说明
连接器
数据库变更订阅
MongoDB 数据订阅
MySQL 数据订阅
PostgreSQL 数据订阅
MySQL 订阅消息官方格式说明
MySQL 订阅消息 canal 格式说明
连接器订阅 PostgreSQL 时用户权限设置参考
数据处理
数据处理规则说明
正则提取
JsonPath 说明
自建集群接入说明(CLB 方式)
连接器访问 CLS、COS 等服务的授权说明
什么是信令表
常见问题
实例问题
Topic 问题
Consumer Group 问题
客户端问题
网络问题
限流问题
监控问题
消息问题
概念问题
连接器问题
任务相关问题
数据上报相关问题
数据处理相关问题
数据转存相关问题
数据订阅相关问题
服务等级协议
联系我们
词汇表
Download PDF
消费数据异常
最后更新时间:2024-01-09 14:57:56
下载PDF
问题概述
消费数据异常。
排查思路
在 CKafka 控制台监控页面查看流量监控情况,观察是否存在波峰,如果存在则通过升级实例大小解决。
查看消费分组是否超过数量。
如果因为网络频繁 rebalance,建议调整客户端超时时间。
是否拉取过期的 offset,消息过期会被删除,如果用过期 offset 拉取会失败。
本页内容是否解决了您的问题?
是
否
您也可以
联系销售
或
提交工单
以寻求帮助。
本页内容是否解决了您的问题?
是
否
您也可以
联系销售
或
提交工单
以寻求帮助。
联系我们
联系我们,为您的业务提供专属服务。
联系我们
技术支持
如果你想寻求进一步的帮助,通过工单与我们进行联络。我们提供7x24的工单服务。
提交工单
7x24 电话支持
本页内容是否解决了您的问题?