[
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)
