TDMQ for CKafka
- Release Notes and Announcements
- Product Introduction
- Purchase Guide
- Billing Overview
- Getting Started
- Obtaining Access Permission
- VPC Access
- Step 4. Send/Receive Messages
- Access via Public Domain Name
- Step 5. Send/Receive Messages
- Operation Guide
- Instance Management
- Topic Management
- Instance Topic
- Elastic Topic
- Consumer Group
- Monitoring and Alarms
- Smart Ops
- Permission Management
- Tag Management
- Migration to Cloud
- CKafka Connector
- Task Management
- Creating Data Access Task
- Creating Data Distribution Task
- Simple Data Processing
- Practical Tutorial
- Practical Tutorial of CKafka Client
- Connector Practical Tutorial
- Reporting over HTTP
- Querying Subscription to Database Change Info
- Log Access
- Troubleshooting
- Topic Failures
- Consumer Group Failures
- Client Failures
- API Documentation
- Making API Requests
- DataHub APIs
- ACL APIs
- Topic APIs
- Instance APIs
- Other APIs
- SDK Documentation
- SDK for Java
- SDK for Python
- SDK for Node.js
- SDK for Connector
- Elastic Topic Message Sending and Receiving
- General References
- Connector
- Database Change Subscription
- FAQs
Existence of Partition Message Heap
Last updated: 2024-01-09 14:57:56
Issue Description
There are always heaped messages in some partitions as displayed on the monitoring page.
Possible Causes
The producer keeps producing messages to the partition while the consumer never consumes these messages.
There are insufficient consumers in the consumer group or the consumption speed is too slow.
The consumer does not consume messages in certain partitions due to bugs.
Solutions
The producer keeps producing messages to the partition while the consumer never consumes these messages
You can restart the client if messages in some partitions are not consumed. If the problem persists, you can either check the client logs first or submit a ticket for assistance.
There are insufficient consumers in the consumer group or the consumption speed is too slow
Try increasing the number of consumers to improve consumption speed.
The consumer does not consume messages in certain partitions due to bugs
Check the local logs of the consumer to see whether exceptions exist.
Was this page helpful?
You can also Contact Sales or Submit a Ticket for help.
Yes
No