Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Won't Do
-
0.10.2.0
-
None
-
None
Description
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
WorkerTask#stopping
is set to true and only then
SourceTask.stop()
is called. This stopping flag prevents WorkerSourceTask from further ingestion (exit from
while ( !isStopped()))
.
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?