pauseConsumption
and resumeConsumption
APIs, which are used to pause and resume ingestion of a stream. watch the following video, or complete the tutorial below, starting with the Prerequites.
For changes to the table configuration, you don’t need to pause and resume; use the forceCommit API
.
Pinot Version | 1.0.0 |
---|---|
Code | startreedata/pinot-recipes/pause-resume |
jq
to structure the data in the key:payload
structure that Kafka expects: