java - spring-cloud-starter-stream-kafka 不会创建提供给 spring.boot.cloud.stream.bindings.output.destination 的主题

Question

我在 Spring Boot 应用程序中为 kafka 使用 spring-cloud-starter-stream-kafka 和 spring-cloud-stream jar。

jar 的版本是 1.1.1.RELEASE，我们正在创建名为 Test 的生产者。同样，以下是 application.yml 文件。

spring.boot.cloud.stream.bindings.output:
                                    destination: Test
                                    content-type: application/octet-stream
                                    producer:
                                      headerMode: raw
                                      requiredGroups: testConsumerGroup

问题是有时当我们在 docker 中运行应用程序(使用 docker-compose)而不是创建测试主题时，它会创建“输出”作为主题。对于 kafka，我使用 wurstmeister/kafka(标签 0.9.0.1-1)图像和 wurstmeister/zookeeper。尝试更新属性但不起作用。

更新:调试后了解到 BindingServiceProperties 不保存绑定(bind)，因此 Spring Cloud Stream 将创建主题作为“输出”

Answer 1

看起来这个版本的库有错误。因此，更新了库的版本，现在它工作正常。