You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on May 12, 2021. It is now read-only.
I decided to only fix #21, not #20. I think #20 requires some judgement about the best way to do that and didn't feel like I could make that decision. Thanks!
Hi there,
First off, great project, thanks so much for creating it.
I noticed that pause and resume commands are using
POST
when talking to the Kafka Connect REST API instead ofPUT
Specifically, these methods should be using
PUT
:https://github.com/datamountaineer/kafka-connect-tools/blob/master/src/main/scala/com/datamountaineer/connect/tools/RestKafkaConnectApi.scala#L198
https://github.com/datamountaineer/kafka-connect-tools/blob/master/src/main/scala/com/datamountaineer/connect/tools/RestKafkaConnectApi.scala#L206
This is the result printed from the Connect Worker:
Note the HTTP 405 response.
The API for these is specified here:
http://docs.confluent.io/3.1.2/connect/restapi.html#put--connectors-(string-name)-pause
I can submit a PR for these changes if you'd like. Thanks!
The text was updated successfully, but these errors were encountered: