Stay organized with collections
Save and categorize content based on your preferences.
Streaming processing operations
From release v1.4.0 onwards, you can start and stop the stream processing using
the API and the web interface. This is a convenient feature that lets you
stop the ingestion in case of a configuration error. This is convenient, because
having an erroneous configurations might result in the messages being rejected
and sent to the dead-letter queue (which might take more manual effort to
replay them back), or erroneously parsed messaged persisted in tables
(which will need manual seek and removal).
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-25 UTC."],[],[],null,["# Streaming processing operations\n===============================\n\nFrom release v1.4.0 onwards, you can start and stop the stream processing using\nthe API and the web interface. This is a convenient feature that lets you\nstop the ingestion in case of a configuration error. This is convenient, because\nhaving an erroneous configurations might result in the messages being rejected\nand sent to the dead-letter queue (which might take more manual effort to\nreplay them back), or erroneously parsed messaged persisted in tables\n(which will need manual seek and removal).\n\nThe API provides the following functionalities:\n\n- Start the ingestion.\n- Stop the ingestion.\n- Getting the status of the ingestion.\n\n| **Note:** Stopping or starting the ingestion impacts all of the services involved in all the processing pipelines. All of the processing metrics in the monitoring dashboard will indicate that they are stopped, and the internal queues depth won't change."]]
