Spring Cloud Stream Kafka Binder函数式批量消费无法接收消息问题求助

核心疑问解答 #

3.0.x版本的Spring Cloud Stream确实存在该问题：只要项目代码中存在标注了@EnableBinding的类，无论该类是否配置了独立的@Profile、是否会被实例化，框架都会默认禁用函数式消费模型，和Profile无关。
这个问题是3.0.x正式版的已知缺陷，你查到的快照版修复记录属实，但修复代码没有合入3.0.11正式版。

可行解决方案 #

• 方案1：不升级版本，强制开启函数式支持
  在你的processing配置文件中追加如下配置，覆盖框架的自动禁用逻辑：

  spring.cloud.stream.function.enabled=true
  

  配置添加后重启应用，检查启动日志中是否不再出现Functional binding is disabled的提示，确认函数式绑定加载正常即可，你现有的批量消费配置无需额外修改即可生效。
• 方案2：升级Spring Cloud Stream版本
  升级到3.1.x及以上的稳定版本，该版本已经修复了该缺陷，支持@EnableBinding和函数式模型共存，只要两类配置的@Profile不冲突，就可以同时正常工作。
• 方案3：全量迁移到函数式模型
  把原有基于@StreamListener的消费逻辑全部改造为函数式实现，移除项目中所有的@EnableBinding注解，从根源上消除冲突，这也是官方推荐的迁移方案。

内容的提问来源于stack exchange，提问作者APK