[
https://issues.apache.org/jira/browse/KAFKA-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142502#comment-15142502
]
Krzysztof Dębski commented on KAFKA-3225:
-----------------------------------------
I am quite new to Kafka (two weeks of experience as a user).
I can only guess - maybe task.commit(); should be added to method
finishSuccessfulFlush in class
org.apache.kafka.connect.runtime.WorkerSourceTask.
This is only a guess. Somebody more experienced should look to it.
> Method commit() of class SourceTask never invoked
> -------------------------------------------------
>
> Key: KAFKA-3225
> URL: https://issues.apache.org/jira/browse/KAFKA-3225
> Project: Kafka
> Issue Type: Bug
> Components: copycat
> Affects Versions: 0.9.0.0
> Environment: Windows 8.1
> Reporter: Krzysztof Dębski
> Assignee: Ewen Cheslack-Postava
>
> In the class org.apache.kafka.connect.source.SourceTask there is the
> following method:
> {code} /**
> * <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.
> }{code}
> 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().
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
