Reset Pipeline Offset
Reset the Kafka Offset of a specific stream processing pipeline.
Prerequisites
A stream processing pipeline is created with the Stream Processing service, and the status of the pipeline is Paused or Stopped.
Request Parameters (URI)
| Name |
Location (Path/Query) |
Mandatory/Optional |
Data Type |
Description |
|---|
| pipelineId |
Path |
Mandatory |
String |
The stream processing pipeline ID, which can be found on the EnOS Management Console > Stream Processing > Stream Operation page. |
| orgId |
Query |
Mandatory |
String |
The organization ID. How to get the orgId>> |
Response Parameters
| Name |
Data Type |
Description |
|---|
| data |
String |
Returns an empty string upon success. |
Error Code
| Code |
Error Information |
Description |
|---|
| 61108 |
stream processing pipeline does not exit. |
Stream processing pipeline does not exist. Please check the pipeline ID. |
| 61168 |
Failed to get the Kafka average rate. |
Failed to get the average rate of Kafka input records. |
Sample
Request Sample
url: https://{apigw-address}/streaming/v2.0/streaming/pipeline/{pipelineId}/offset?orgId=yourOrgId
method: POST
Return Sample
{
"code": 0,
"msg": "OK",
}
SDK Samples
You can access the SDK samples for stream processing service on GitHub: