我正在将Spring Cloud Stream应用程序从Sping Boot 2.7.6升级到3.0.0到目前为止,我只需要更改一些代码就可以编译项目
KafkaHeaders.MESSAGE_KEY
至KafkaHeaders.KEY
KafkaTestUtils.getSingleRecord()
现在需要Duration作为第三个参数,而不是long
但在启动应用程序时,org.springframework.cloud.stream.endpoint.BindingsEndpoint
的自动装配不再起作用:
Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 'org.springframework.cloud.stream.endpoint.BindingsEndpoint' available: expected at least 1 bean which qualifies as autowire candidate. Dependency annotations: {}
是否有文档记录,说明必须执行哪些操作才能使其正常工作?
这是我的sample project,主分支包含Sping Boot 2.7.6的工作代码。
1条答案
按热度按时间blmhpbnm1#
在你的spring-boot-3分支中,我看到你把Spring Cloud Stream设置为
3.2.6
。你需要使用一个兼容的4.0.x
版本。把它更新到4.0.0-SNAPSHOT
(或者任何4.0.0
版本),绑定端点应该是可用的。我刚刚在我这边用那个更改验证了它。