[ https://issues.apache.org/jira/browse/HUDI-7517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated HUDI-7517: --------------------------------- Labels: pull-request-available (was: ) > 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 > Priority: Major > Labels: pull-request-available > > 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)