add jmx for cruise control

canonical · Jul 18, 2024 · 82cba59 · 82cba59
1 parent c266f9c
commit 82cba59
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/snap/local/etc/cruise-control/jmx_cruise_control.yaml b/snap/local/etc/cruise-control/jmx_cruise_control.yaml
@@ -0,0 +1,5 @@
+  lowercaseOutputName: true
+  rules:
+  - pattern: kafka.cruisecontrol<name=(.+)><>(\w+)
+    name: kafka_cruisecontrol_$1_$2
+    type: GAUGE
diff --git a/snap/local/opt/cruise-control/bin/start-wrapper.bash b/snap/local/opt/cruise-control/bin/start-wrapper.bash
@@ -2,7 +2,13 @@
 
 set -e
 
-unset KAFKA_JMX_OPTS
+# Cruise control uses the same var for JMX metrics. To allow both to be used on the same machine, 
+# use a specific var for CC and override during startup.
+if [ "x$CC_JMX_OPTS" != "x" ]; then
+    export KAFKA_JMX_OPTS=${CC_JMX_OPTS}
+else
+    unset KAFKA_JMX_OPTS
+fi
 
 if [ "x$KAFKA_LOG4J_OPTS" = "x" ]; then
     export KAFKA_LOG4J_OPTS="-Dcruisecontrol.logs.dir=${LOG_DIR} -Dlog4j.configurationFile=${SNAP_DATA}/etc/cruise-control/log4j.properties -Dcruisecontrol.log.level=${KAFKA_CFG_LOGLEVEL:-INFO}"