cruise-control
cruise-control copied to clipboard
linkedin
Cruise-control is the first of its kind 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 Kaf...
### Observation : Once we provide the configuration ``metric.anomaly.finder.class=com.linkedin.kafka.cruisecontrol.detector.SlowBrokerFinder``, we also need to additionally provide ``metric.anomaly.class=com.linkedin.kafka.cruisecontrol.detector.SlowBrokers`` In absence of ``metric.anomaly.class`` configuration, it defaults to the parent class ``com.linkedin.kafka.cruisecontrol.detector.KafkaMetricAnomaly`` and below...
In our Kafka setup, we have a well balanced cluster. The only operational thing happening to this cluster is sometimes AWS decides to kill some nodes. When those AWS maintenance...
I am proposing the following cluster wide equal distribution goal to the community to see whether people thinks it belong to cruise control philosophy. We have many dedicated Kafka clusters...
An example of the current state output is `ExecutorState: {state: INTER_BROKER_REPLICA_MOVEMENT_TASK_IN_PROGRESS, pending/in-progress/aborting/finished/total inter-broker partition movement 268569/48/0/7512/276129, completed/total bytes(MB): 3803670/195202695, maximum concurrent inter-broker partition movements per-broker: 2, triggeredUserTaskId: fded915c-6341-4c56-863f-04bb90051207, triggeredTaskReason: luwang...
As recently @mohitpali added a BrokerSetAwareGoal, we need to visualize the information in kafka_cluster_state. The first step is to port the BrokerSetResolver instance to the KafkaClusterState. Notice that we don't...
``` 2022/08/10 01:57:51.461 ERROR [KafkaCruiseControlServlet] [qtp1636178473-23] [kafka-cruise-control] [] Error processing POST request '/topic_configuration' due to: 'com.linkedin.kafka.cruisecontrol.exception.KafkaCruiseControlException: java.lang.NullPointerException'. java.util.concurrent.ExecutionException: com.linkedin.kafka.cruisecontrol.exception.KafkaCruiseControlException: java.lang.NullPointerException at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2022) ~[?:?] at com.linkedin.kafka.cruisecontrol.servlet.handler.async.AbstractAsyncRequest.getResponse(AbstractAsyncRequest.java:57) ~[cruise-control-2.5.98.jar:?] at...
Hello, I'm having some issues in cruise control. I'm using confluent version 6.2.1-1 and i've installed CC on my cluster but the thing is i d'ont have any metrics published...
Running Cruise Control in a Kafka cluster and getting warnings. Should I be concerned about these warnings? Here is a sample: ConsumerConfig:384 - The configuration 'broker.metrics.window.ms' was supplied but isn't...
