Skip to content
This repository has been archived by the owner on Oct 23, 2024. It is now read-only.

Latest commit

 

History

History
43 lines (29 loc) · 1.54 KB

cruise-control.md

File metadata and controls

43 lines (29 loc) · 1.54 KB

Cruise Control

Overview

KUDO Kafka operator comes with builtin integration of Cruise Control.

Cruise Control is a tool to fully automate the dynamic workload rebalance and self-healing of a kafka cluster. It provides great value to Kafka users by simplifying the operation of Kafka clusters.

Cruise Control integration is disabled by default.

Setup Cruise Control

Start Cruise Control

Update the instance with ENABLE_CRUISE_CONTROL set to start Cruise Control alongside the KUDO Kafka instance.

$ kubectl kudo update --instance=kafka \
  -p ENABLE_CRUISE_CONTROL=true

Advanced Options

Parameter Description Example
CRUISE_CONTROL_PORT Port for the Cruise Control server to listen to
  • 9090 (default)
CRUISE_CONTROL_WEBSERVER_API_URLPREFIX Cruise Control REST API default prefix
  • "/kafkacruisecontrol/*" (default)
CRUISE_CONTROL_WEBSERVER_UI_URLPREFIX Cruise Control REST Web UI default path prefix
  • "/*" (default)

Disable Cruise Control

To disable Cruise Control, update the instance with ENABLE_CRUISE_CONTROL set to false, using the following command:

$ kubectl kudo update --instance=kafka \
  -p ENABLE_CRUISE_CONTROL=false

Limitations

Currently Cruise Control works with Kafka protocol PLAINTEXT only. It will not work if Kerberos and or TLS is enabled in the Kafka instance. Future releases of KUDO Kafka will address this limitation through a Cruise Control operator.