From 42fab2cfcf20c9c0e01725b62cedb6cf3319034b Mon Sep 17 00:00:00 2001 From: Ubuntu Date: Mon, 16 Dec 2024 12:01:35 +0000 Subject: [PATCH] zookeeper depreciated, added bootstrap to retrive necessary information --- kafka-reassign-tool | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/kafka-reassign-tool b/kafka-reassign-tool index 93f4a7a..76bd24a 100755 --- a/kafka-reassign-tool +++ b/kafka-reassign-tool @@ -80,13 +80,14 @@ def get_brokers() brokers = $1.split(',').collect(&:strip).collect(&:to_i) end } + puts "brokers: #{brokers}" brokers end def get_topics() result = run(get_kafka_root + '/bin/kafka-topics.sh', [ - '--zookeeper', get_zk_url, + '--bootstrap-server', 'localhost:9092', '--list' ]) result[:out].lines.collect(&:strip) @@ -116,7 +117,7 @@ def get_current_assignments(topics, brokers) topics_file.close result = run(get_kafka_root + '/bin/kafka-reassign-partitions.sh', [ - '--zookeeper', get_zk_url, + '--bootstrap-server', 'localhost:9092', '--topics-to-move-json-file', topics_file.path, '--broker-list', brokers.join(','), '--generate'