Support Questions
Find answers, ask questions, and share your expertise

kafka connect config properties update via API

kafka connect config properties update via API

Explorer

i am trying to update kafka connect config properties via API using PUT and POST methods. but its failing and got error (method not allowed), How can i update that config file?

1 REPLY 1

Re: kafka connect config properties update via API

Contributor

Hey @Manoj690,

 

Thanks for reaching out to the Cloudera community.

 

You can execute a PUT request using the mentioned path "/connectors/<Connector_name>/config" to update the configuration for an existing connector. Also, pass a JSON object with the update parameter/s in the PUT request.

 

Example request:

 

PUT /connectors/<Connector_name>/config

 

Accept: application/json

 

{
"flush.size": "100",
"rotate.interval.ms": "1000"
}

 

Let me know if this helps.