I'm trying to use the Connector API to write data to a backing store (HDFS for now, but probably something like S3 later) for potential replay back into Kafka later. However, I can't seem to find how to reset the offsets for the SinkConnector.
I've found the rewind() function on the WorkerSinkTask: https://github.com/apache/kafka/blob/c9485b78a6e43747daf1314ae9532839fb7bc810/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java#L396 However, WorkerSinkTask doesn't seem to provide any access to the WorkerSinkTaskContext, even though the latter has accessors to reset the offsets with. Without those, I'm not sure what the purpose of the rewind method is, since it doesn't seem to be possible to set the offsets at all. Is this by design? Thanks. -Jack Lund Braintree Payment Systems
