[jira] [Created] (HUDI-7517) Add ability to reset the checkpoint for kafka source

["Rajesh Mahindra (Jira)" <ji...@apache.org>]

Rajesh Mahindra created HUDI-7517:
-------------------------------------

             Summary: Add ability to reset the checkpoint for kafka source
                 Key: HUDI-7517
                 URL: https://issues.apache.org/jira/browse/HUDI-7517
             Project: Apache Hudi
          Issue Type: Improvement
            Reporter: Rajesh Mahindra


Add ability to reset the checkpoint for kafka source. The use case is that, say we switch the kafka cluster or topic name, or may be we want to re-ingest some messages and restart from earliest offset, we may not have a specific offset to reset to. With this change, we can just reset the checkpoint to a new kafka cluster (and/or topic name) or the same kafka cluster/topic and just pick up from earliest or latest offset without knowledge of exact kafka offset.



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