2017-11-18 22 views
0

私はKafka-dockerを使い始めました。そして、私はドッキングウィンドウ内の次のコマンドを使用してトピックを作成するために、風袋引きだ:例外:ドッカー内にカフカトピックを作成するとき、パーティションは認識されたオプションではありません。

./kafka-topics.sh --create --zookeeper zoo1:2181 --replication-factor 3 --partition 2 --topic test 

それは私に次のエラーguive:

Exception in thread "main" joptsimple.UnrecognizedOptionException: partition is not a recognized option 
    at joptsimple.OptionException.unrecognizedOption(OptionException.java:108) 
    at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510) 
    at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56) 
    at joptsimple.OptionParser.parse(OptionParser.java:396) 
    at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:340) 
    at kafka.admin.TopicCommand$.main(TopicCommand.scala:43) 
    at kafka.admin.TopicCommand.main(TopicCommand.scala) 

を私はhostsファイルに次の行を追加します:

127.0.0.1  kafka1 
127.0.0.1  zoo1 

答えて

4

それは--partitionはありませんが、--partitions

関連する問題