Kafka命令行常用命令说明



##查看topic分布情况kafka-list-topic.sh

实际是通过

-create-topic.sh 

-create-topic.sh 

##重新分配分区kafka-reassign-partitions.sh

bin/kafka-reassign-partitions.sh --topics-to-move-json-file topics-to-move.json --broker-list "171" --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --execute  cat topic-to-move.json {"topics":      [{"topic": "test2"}],      "version":1 }

-console-consumer.sh --zookeeper 

--topic test 

192.168.197.170:2181,192.168.197.171:2181.json


{
 "partitions":
  [
    {"topic": "click", "partition": 0},
    {"topic": "click", "partition": 1},
    {"topic": "click", "partition": 2},
    {"topic": "click", "partition": 3},
    {"topic": "click", "partition": 4},
    {"topic": "click", "partition": 5},
    {"topic": "click", "partition": 6},
    {"topic": "click", "partition": 7},

    {"topic": "play", "partition": 1},
    {"topic": "play", "partition": 2},
    {"topic": "play", "partition": 3},
    {"topic": "play", "partition": 4},
    {"topic": "play", "partition": 5},
    {"topic": "play", "partition": 6},
    {"topic": "play", "partition": 7}

  ]
}

相关内容