新开发的软件老被系统拦截有什么办法解决吗？

指定topic的分区和副本

通过kafka命令行工具

kafka-topics.sh --create --topic myTopic --partitions 3 --replication-factor 1 --bootstrap-server localhost:9092

执行代码时指定分区个数