kafka git commit: KAFKA-2741: Make SourceTaskContext and SinkTaskContext interfaces and keep implementations in runtime jar.
Subject kafka git commit: KAFKA-2741: Make SourceTaskContext and SinkTaskContext interfaces and keep implementations in runtime jar.
* Context passed to SinkTasks, allowing them to access utilities in the copycat runtime.
* @param tp the topic partition to reset offset.
* @param offset the offset to reset to.
* issues. SinkTasks use this method to set how long to wait before retrying.
* @param timeoutMs the backoff timeout in milliseconds.
* Get the current set of assigned TopicPartitions for this task.
* Pause consumption of messages from the specified TopicPartitions.
* Resume consumption of messages from previously paused TopicPartitions.
* Get the OffsetStorageReader for this SourceTask.
+        // to work with. Any rewinding will be handled immediately when polling starts.
-        // enable exactly once delivery to that system).
rebalance are picked up correctly.
* Get offsets that the SinkTask has submitted to be reset. Used by the Copycat framework.
* Get the timeout in milliseconds set by SinkTasks. Used by the Copycat framework.
* @return the backoff timeout in milliseconds.