From 283beffa4102aa9889744bbe0319db4b2225309c Mon Sep 17 00:00:00 2001 From: Neeraj Sharma Date: Wed, 21 Apr 2021 12:49:30 +0530 Subject: [PATCH] Add check for single-region topic on east regions --- multiregion/scripts/jmx_metrics.sh | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/multiregion/scripts/jmx_metrics.sh b/multiregion/scripts/jmx_metrics.sh index e95324670..9114b43cd 100755 --- a/multiregion/scripts/jmx_metrics.sh +++ b/multiregion/scripts/jmx_metrics.sh @@ -16,13 +16,17 @@ do && BW2=$(docker-compose exec broker-west-2 kafka-run-class kafka.tools.JmxTool --jmx-url service:jmx:rmi:///jndi/rmi://localhost:8092/jmxrmi --object-name kafka.cluster:type=Partition,name=$metric,topic=$topic,partition=0 --one-time true | tail -n 1 | awk -F, '{print $2;}' | head -c 1) \ || BW2=0 + if [ $topic != "single-region" ]; then test "$(docker inspect -f '{{.State.ExitCode}}' $(docker ps -laq --filter="name=broker-east-3"))" = "0" \ && BE3=$(docker-compose exec broker-east-3 kafka-run-class kafka.tools.JmxTool --jmx-url service:jmx:rmi:///jndi/rmi://localhost:8093/jmxrmi --object-name kafka.cluster:type=Partition,name=$metric,topic=$topic,partition=0 --one-time true | tail -n 1 | awk -F, '{print $2;}' | head -c 1) \ || BE3=0 + fi + if [ $topic != "single-region" ]; then test "$(docker inspect -f '{{.State.ExitCode}}' $(docker ps -laq --filter="name=broker-east-4"))" = "0" \ && BE4=$(docker-compose exec broker-east-4 kafka-run-class kafka.tools.JmxTool --jmx-url service:jmx:rmi:///jndi/rmi://localhost:8094/jmxrmi --object-name kafka.cluster:type=Partition,name=$metric,topic=$topic,partition=0 --one-time true | tail -n 1 | awk -F, '{print $2;}' | head -c 1) \ || BE4=0 + fi REPLICAS=$((BW1 + BW2 + BE3 + BE4)) echo "$topic: $REPLICAS"