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

Reply via email to