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

Reply via email to