[jira] [Resolved] (KAFKA-3225) Method commit() of class SourceTask never invoked

["Ewen Cheslack-Postava (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ewen Cheslack-Postava resolved KAFKA-3225.
------------------------------------------
       Resolution: Fixed
    Fix Version/s: 0.9.1.0

Issue resolved by pull request 909
[https://github.com/apache/kafka/pull/909]

> 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
>             Fix For: 0.9.1.0
>
>
> 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)