错误原因:

kafka的配置文件 consumer.properties 里面的 group.id 和 idea 中项目配置文件中的 group-id 设置的不一样。

解决办法:

设置为相同值就可以了。

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐