2016-11-10 12 views
2

kafkaでは、./kafka-topics.shコマンドでトピックを作成しました。コマンドは、トピックのテストのための8つのパーティションでserver.propertiesのパーティション数とトピック作成時のパーティション数のあいまいさApacheのkafkaのパーティションパラメータ

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 8 --topic test 

ようになり、また、デフォルトでnum.partitionsパラメータは、今私の具体的な質問がそれである1

ありましたカフカブローカーでserver.properties構成は、そこにありますトピック・テストのパーティションにあいまいさが生じません。トピック作成時に言及されたパーティションまたはnum.partitionserver.propertiesにあります。

答えて

0

オンデマンドでトピックを作成するように設定できます。つまり、存在しないトピックにメッセージを送信しようとすると、num.partitionsというプロパティーがserver.propertiesに指定されたパーティションの数でトピックが自動的に作成されます。あなたはトピックが--partitionsとして指定されたパーティションの数で作成されます

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 8 --topic test 

を使って自分でトピックを作成しようとしている場合は、あなたのケースでは8になり、財産num.partitionsは無視されます。

+0

ありがとう...私は私の解決策を得ました... –

関連する問題