☰

kafka トピックのパーティション数を取得する 質問する

tag-icon • tag-icon java apache-kafka
kafka トピックのパーティション数を取得する 質問する

コードから任意の Kafka トピックのパーティション数を取得するにはどうすればよいでしょうか。多くのリンクを調べましたが、どれも機能しないようです。

いくつか例を挙げると:

http://grokbase.com/t/kafka/users/148132gdzk/find-topic-partition-count-through-simpleclient-api

http://grokbase.com/t/kafka/users/151cv3htga/get-replication-and-partition-count-of-a-topic

http://qnalist.com/questions/5809219/get-replication-and-partition-count-of-a-topic

同様の議論のように見えます。

また、SO にも同様のリンクがありますが、これには有効な解決策がありません。

ベストアンサー1

ディレクトリに移動しますkafka/bin。

次にこれを実行します:

./kafka-topics.sh --describe --zookeeper localhost:2181 --topic topic_name

必要なものは の下に表示されますPartitionCount。

Topic:topic_name        PartitionCount:5        ReplicationFactor:1     Configs:
        Topic: topic_name       Partition: 0    Leader: 1001    Replicas: 1001  Isr: 1001
        Topic: topic_name       Partition: 1    Leader: 1001    Replicas: 1001  Isr: 1001
        Topic: topic_name       Partition: 2    Leader: 1001    Replicas: 1001  Isr: 1001
        Topic: topic_name       Partition: 3    Leader: 1001    Replicas: 1001  Isr: 1001
        Topic: topic_name       Partition: 4    Leader: 1001    Replicas: 1001  Isr: 1001

zookeeperがKafkaに依存しなくなったバージョンを使用する場合

kafka-topics --describe --bootstrap-server localhost:9092 --topic topic_name

おすすめ記事