Description
https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3A+First-class+offsets+support+in+Kafka+Connect introduced the new SourceConnector::alterOffsets and SinkConnector::alterOffsets APIs. The FileStreamSourceConnector and FileStreamSinkConnector should implement these new methods to improve the user experience when modifying offsets for these connectors and also to serve as an example for other connectors.
Attachments
Attachments
Issue Links
- is related to
-
KAFKA-15177 MirrorMaker 2 should implement the alterOffsets KIP-875 API
- Resolved
- relates to
-
KAFKA-4107 Support offset reset capability in Kafka Connect
- Resolved
- links to