参考：https://www.jianshu.com/p/9e72b3942c59
原因是在kafka集群kafka/config/server.properties文件中num.patitions = 1. 需要修改分区默认值。
./bin/kafka-topics.sh --zookeeper localhost:2181 --alter --partitions 2 --topic test
kafka Java创建生产者报错：Invalid partition given with record: 1 is not in the range [0...1)
原文：https://www.cnblogs.com/ryu-manager/p/9438863.html