刚接手的spring项目遇到项目启动报Caused by: java.lang.IllegalStateException: The number of expected partitions was: 3, but 1 has been found instead这个错误,经过半天踩坑解决问题,说下具体过程:
1、我本地安装的kafka,用的默认配置即:num.partitions=1。
2、启动项目报错Caused by: java.lang.IllegalStateException: The number of expected partitions was: 3, but 1 has been found instead。
3、修改num.partitions=3,重启kafka和zookeeper,再启动,还是报上面那个错误。
4、经过踩坑排查发现是第一次启动应用的时候已经在分区为1(num.partitions=1)的时候创建了topic,所以再修改num.partitions=3的时候,对已经创建的topic不起作用,所以后面启动应用一直报这个错误。
5、解决方案是用命令修改num.partitions或者把已经创建的topic全部删掉,重新启动应用即可解决问题。
转载请注明:扩产网 » spring连接kafka报The number of expected partitions was: 3, but 1 has been found instead