aboutsummaryrefslogtreecommitdiffstats
path: root/kafka
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@archive.org>2021-09-03 12:23:41 -0700
committerBryan Newbold <bnewbold@archive.org>2021-09-03 12:23:41 -0700
commitcf1bf8001d426c41143436cb578dc64d67d1ca0f (patch)
tree22b31d45384ae5ff97e1559d13bf0f48521903c1 /kafka
parent660fe9eeb3ec2bd0f4ae8c9c62932098c1a7b625 (diff)
downloadsandcrawler-cf1bf8001d426c41143436cb578dc64d67d1ca0f.tar.gz
sandcrawler-cf1bf8001d426c41143436cb578dc64d67d1ca0f.zip
kafka re-balancing tweaks
Diffstat (limited to 'kafka')
-rw-r--r--kafka/howto_rebalance.md3
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/howto_rebalance.md b/kafka/howto_rebalance.md
index d68b205..093740a 100644
--- a/kafka/howto_rebalance.md
+++ b/kafka/howto_rebalance.md
@@ -27,7 +27,8 @@ On a kafka broker, go to `/srv/kafka-broker/kafka-*/bin`, generate a plan, then
inspect the output:
./kafka-reassign-partitions.sh --zookeeper localhost:2181 --broker-list "280,281,284,285,263" --topics-to-move-json-file /tmp/topics_to_move.json --generate > /tmp/reassignment-plan.json
- cat /tmp/reassignment-plan.json | rg '^\{' | tail -n1 > /tmp/new-plan.json
+ cat /tmp/reassignment-plan.json | rg '^\{' | head -n1 | jq . > /tmp/old-plan.json
+ cat /tmp/reassignment-plan.json | rg '^\{' | tail -n1 | jq . > /tmp/new-plan.json
cat /tmp/reassignment-plan.json | rg '^\{' | jq .
If that looks good, start the rebalance: