原因是在kafka的server.properties文件中设置有默认的partition,num.patitions. 可修改分区默认值。
partitions在是在创建topic的时候默认创建的配置文件中指定的partitions节点个数,只对新创建的topic生效。如果要自定义指定partition的值,可以通过命令实现。
./bin/kafka-topics.sh --zookeeper localhost:2181 --alter --partitions 2 --topic test