Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
Nifi source is not stoppable right now. To make it stoppable, is must implement StoppableFunction. Implementing method stop() must ensure, that the source stops receiving new messages from Nifi and issues a final checkpoint. Afterwards, run() must return.
When implementing this, keep in mind, that the gathered checkpoint might later be used as a savepoint.
Attachments
Issue Links
- links to