Search code examples
pipelinestreamsets

Reset Origin of a StreamSets Pipeline using another pipeline


I want to reset the origin of a StreamSets pipeline, using another pipeline. I made a pipeline that sends 1 useless record to HTTP client component. The HTTP client contains the RESTFUL URL to reset the origin of a pipeline. It's something like that:

Resource URL: http://<hostname>:<port>/rest/v1/pipeline/StreamSetsPipelinec78f8739-8adb-47ad-beaa-77b3de60038d/resetOffset

HTTP method is POST

I tested it and it doesn't reset the origin.

Can anyone help me?


Solution

    • Have you tried using curl to test it first? For example, assuming you're targeting SDC (not SCH), something like this should work: curl -u admin:admin -X POST http://10.0.0.199:18630/rest/v1/pipeline/SDCHTTPClientd8bc16bc-4b4a-49cd-ba4c-41d7831ff5bd/resetOffset -H "X-Requested-By: SDC"
    • From HTTP Client, what do you have set for auth type and are you passing the right credentials?
    • Are you passing header attribute X-Requested-By?
    • In any case, are you getting any errors?
    • Note that this REST API endpoint does not return response body... just response code 200