question Re: is it possible to stop/start kafka service each kafka node separated not in parallel in Support Questions

is it possible to stop/start kafka service each kafka node separated not in parallel

mike_bronson7 — Thu, 27 Feb 2020 20:07:13 GMT

hi all

in our cluster HDP - 2.6.4 , we have kafka cluster with 11 nodes ( 11 machines )

restart the kafka service , from AMBARI REST API , will stop/start is brutal

when we do it from rest API then its cause corrupted indexes files in kafka topic partitions

what we search is , ambari rest API that do the restart in parallel

for example

first stop kafka01

then

start kafka01

wait until alert gone (from ambari)

then stop kafka02 , and start kafka02

etc....

is this process could be done by ambari rest API?

Re: is it possible to stop/start kafka service each kafka node separated not in parallel

jsensharma — Fri, 28 Feb 2020 03:34:05 GMT

@mike_bronson7

Looks like you have asked a very similar query on the other thread :

https://community.cloudera.com/t5/Support-Questions/amari-rest-API-how-to-stop-service-on-specific-host/m-p/290651

Re: is it possible to stop/start kafka service each kafka node separated not in parallel

jsensharma — Fri, 28 Feb 2020 03:40:54 GMT

@mike_bronson7

In addition to my previous comment:
Ambari provides option to "Rolling Restart Kafka Brokers" (one by one). In the ambari UI when you click on

Ambari UI --> Kafka --> Service Actions (drop down) --> "Restart Kafka Brokers"

Then it basically shows the Rolling restart Settings like. You can decide how much time in your env one Kafka Broker full restart taks and then after how much time do you want other Kafka broker restart will be scheduled by Ambari.

It can also be achieved using the API call as following:

# curl -iskH "X-Requested-By: ambari" -u admin:admin -X POST -d '[{"RequestSchedule":{"batch":[{"requests":[{"order_id":1,"type":"POST","uri":"/clusters/NewCluster/requests","RequestBodyInfo":{"RequestInfo":{"context":"_PARSE_.ROLLING-RESTART.KAFKA_BROKER.1.3","command":"RESTART"},"Requests/resource_filters":[{"service_name":"KAFKA","component_name":"KAFKA_BROKER","hosts":"testnode2.example.com"}]}},{"order_id":2,"type":"POST","uri":"/clusters/NewCluster/requests","RequestBodyInfo":{"RequestInfo":{"context":"_PARSE_.ROLLING-RESTART.KAFKA_BROKER.2.3","command":"RESTART"},"Requests/resource_filters":[{"service_name":"KAFKA","component_name":"KAFKA_BROKER","hosts":"testnode3.example.com"}]}},{"order_id":3,"type":"POST","uri":"/clusters/NewCluster/requests","RequestBodyInfo":{"RequestInfo":{"context":"_PARSE_.ROLLING-RESTART.KAFKA_BROKER.3.3","command":"RESTART"},"Requests/resource_filters":[{"service_name":"KAFKA","component_name":"KAFKA_BROKER","hosts":"testnode5.example.com"}]}}]},{"batch_settings":{"batch_separation_in_seconds":"121","task_failure_tolerance":1}}]}}]' ttp://testnode1.example.com:8080/api/v1/clusters/NewCluster/request_schedules