[
https://issues.apache.org/jira/browse/HUDI-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446553#comment-17446553
]
sivabalan narayanan commented on HUDI-1201:
-------------------------------------------
[~Trevorzhang] : we do already have this support I guess (auto.offset.reset).
can we close this out. Or are you looking for something else.
> HoodieDeltaStreamer: Allow user overrides to read from earliest kafka offset
> when commit files do not have checkpoint
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: HUDI-1201
> URL: https://issues.apache.org/jira/browse/HUDI-1201
> Project: Apache Hudi
> Issue Type: Improvement
> Components: DeltaStreamer
> Reporter: Balaji Varadarajan
> Assignee: Trevorzhang
> Priority: Major
> Fix For: 0.11.0
>
>
> [https://github.com/apache/hudi/issues/1985]
>
> It would be easier for user to just specify deltastreamer to read from
> earliest offset instead of implementing -initial-checkpoint-provider or
> passing raw kafka checkpoints when the table was initially bootstrapped
> through spark.write().
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
