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