[HUDI-7511] Offset range calculation in kafka should return all topic partitions

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.15.0, 1.0.0
• Component/s: deltastreamer
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: sivabalan narayanan
• Created: 18/Mar/24 03:24
• Updated: 09/Jun/24 23:22
• Resolved: 09/Jun/24 23:22

Description

after https://github.com/apache/hudi/pull/10869 got landed, we are not returning every topic partition in final ranges. But for checkpointing purpose, we need to have every kafka topic partition in final ranges even if we are not consuming anything. 

 

Issue Links

• links to: GitHub Pull Request #10875