Spring Cloud Stream与Spring Boot 3+

Question

SB3.0.6 和 spring-cloud-stream:4.0.2 是否存在一些兼容性问题？我们从 2.7.8 迁移到 3.0.6，并且在测试期间使用相同配置 (application.yml) 的 AbstractDestination 类中“自动检测”通道时出现问题。

图书馆为此做好准备了吗？有什么不同的文档吗？

我可以在 Spring Boot 2.2.x / 2.1.x 列的发布列车中看到here，但我对此并不聪明。

任何评论表示赞赏。

问候

Answer 1

我是这个项目的新手，但这是我发现的：

项目设置：

kotlin
azure service bus
spring boot 3.0.6
spring-cloud-stream:4.0.2
spring-cloud-stream-test-binder:4.0.2

流程： 通过 InputDestination 将数据发送到某个主题“address.update-file-records.v1”。

input.send(someByteArray, "address.update-file-records.v1")

Bean定义：

@Bean
fun updateAddress(): Consumer<Message<AddressUpdateRequest>> { return Consumer {}}

主题或相关方法 updateAddress 在任何 application.yml 文件中可见：

spring:
  cloud:
    stream:
      // looks like this is used to import value in beans using @Value(...)
      property:
        destinations:          
          updateAddress-out-0: 
            address.update-file-records.v1
        function.definition: updateAddress;someOtherMethod

      bindings:    
        updateAddress-in-0:
          destination: address.update-file-records.v1

      servicebus:
        bindings:
          updateAddress-in-0:
            consumer:
              maxConcurrentCalls: ${ans.messaging.client.threads.update-address}            

Answer 2

对于我来说，将 Spring boot 3 和 Spring cloud 迁移到 4.0.x 后。 Spring 云流 Kafka 未启动/消费事件。

正如@Gondri 在评论中提到的，

spring.cloud.stream.function.definition

移至

spring.cloud.function.definition

。更改后，它开始工作。