You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by "sivabalan narayanan (Jira)" <ji...@apache.org> on 2024/03/18 03:25:00 UTC

[jira] [Created] (HUDI-7511) Offset range calculation in kafka should return all topic partitions

sivabalan narayanan created HUDI-7511:
-----------------------------------------

             Summary: Offset range calculation in kafka should return all topic partitions 
                 Key: HUDI-7511
                 URL: https://issues.apache.org/jira/browse/HUDI-7511
             Project: Apache Hudi
          Issue Type: Bug
          Components: deltastreamer
            Reporter: sivabalan narayanan


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. 

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)