Major Description
In the class org.apache.kafka.connect.source.SourceTask there is the following method:
/**
* <p>
* Commit the offsets, up to the offsets that have been returned by {@link #poll()}. This
* method should block until the commit is complete.
* </p>
* <p>
* SourceTasks are not required to implement this functionality; Kafka Connect will record offsets
* automatically. This hook is provided for systems that also need to store offsets internally
* in their own system.
* </p>
*/
public void commit() throws InterruptedException {
// This space intentionally left blank.
}
I have created my task which inherits from SourceTask and overrides commit(). In spites of offsets being recorded automatically be Kafka, method commit() is never invoked.
I have downloaded sources of Kafka and imported them to Intelij Idea.
Then I used "Find Usages" command. Idea found only one usage - in comments of method stop().