apache / apache/rocketmq-flink
[Bug] Some messages cannot be consumed if there's new queues added.
Open
- Dominant language
- Java
- Stars
- 174
- Forks
- 104
- PR merge metrics
- No merged PRs in 30d
Description
对于新增的队列，会对其消费位点进行初始化。如果这个期间有消息写入，且 startMode 为 LATEST，则在 initOffset 之前写入新扩容的队列的消息将都无法消费到
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.