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)
