KAFKA-3225 Added test case for missing commit call on WorkerSourceTas…#84

Closed

Jeremy Custenborder (jcustenborder) wants to merge 1 commit into

confluentinc:trunkfrom

jcustenborder:KAFKA-3225

Commits on Feb 12, 2016

KAFKA-3225 Added test case for missing commit call on WorkerSourceTask. Added commitSourceTask() to follow finishSuccessfulFlush() which calls SourceTask.commit() and log exceptions.
Jeremy Custenborder (jcustenborder)
committed