[
https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169748#comment-16169748
]
Stelios BOURAZANIS commented on KAFKA-4107:
-------------------------------------------
This is an extremely usefull tool, as Kafka connect implementations usually
store a unique ID on a specif topic, and selected partition (based on a
calculated data key) , to check for new records.
If this ID is reset from the source, then no way to reset the offset of the
corresponding partition of that offset topic for this connector. One could
delete the offset partition and restart the workers, but that has implications
on certain type of source connectors.
The tool should have the ability to read a certain offset per topic partition
and print the value and the key of the data in that offset. The tool should
have the ability to write a new message in a specific topic/partition and use a
user specific value ( 0 to reset) as a value.
> Support offset reset capability in Kafka Connect
> ------------------------------------------------
>
> Key: KAFKA-4107
> URL: https://issues.apache.org/jira/browse/KAFKA-4107
> Project: Kafka
> Issue Type: Improvement
> Components: KafkaConnect
> Reporter: Jason Gustafson
>
> It would be useful in some cases to be able to reset connector offsets. For
> example, if a topic in Kafka corresponding to a source database is
> accidentally deleted (or deleted because of corrupt data), an administrator
> may want to reset offsets and reproduce the log from the beginning. It may
> also be useful to have support for overriding offsets, but that seems like a
> less likely use case.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
