[ https://issues.apache.org/jira/browse/KAFKA-5866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883413#comment-16883413 ]
Konstantine Karantasis commented on KAFKA-5866: ----------------------------------------------- Now that https://issues.apache.org/jira/browse/KAFKA-5505 maybe some motivation behind this ticket has been addressed. Besides that, allowing a task to delay shutting down after stop has been signaled might interfere with rebalancing. If there's no objection I'd suggest to close this ticket as "won't fix" cc [~rhauch] [~ewencp] > Let source/sink task to finish their job before exit > ---------------------------------------------------- > > Key: KAFKA-5866 > URL: https://issues.apache.org/jira/browse/KAFKA-5866 > Project: Kafka > Issue Type: Bug > Components: KafkaConnect > Affects Versions: 0.10.2.0 > Reporter: Oleg Kuznetsov > Priority: Major > > My case is about reading files. When task stops to rebalance or for other > reason, I want let it to read file till the end at least. > I found that flag > {code:java} > WorkerTask#stopping > {code} > is set to true and only then > {code:java} > SourceTask.stop() > {code} > is called. This stopping flag prevents WorkerSourceTask from further > ingestion (exit from > {code:java} > while ( !isStopped())) > {code}. > Is it possible to let task to decide to work some more time and possibly > produce more records from the moment of stop() was called on rebalance? -- This message was sent by Atlassian JIRA (v7.6.14#76016)