Description
When a source connector is started, having access to the OffsetStorageReader would allow it to more intelligently configure its tasks based upon the stored offsets. (Currently only the SourceTask implementations can access the offset reader (via the SourceTaskContext), but the SourceConnector does not have access to the offset reader.)
Of course, accessing the stored offsets is not likely to be useful for sink connectors.
Attachments
Issue Links
- relates to
-
KAFKA-4794 Add access to OffsetStorageReader from SourceConnector
- Resolved