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

Question

我在 spring boot 应用程序中使用了 spring-cloud-starter-stream-kafka 和 spring-cloud-stream jars for kafka。

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(Tag 0.9.0.1-1) 图像和 wurstmeister/zookeeper。 尝试更新属性，但不起作用。

更新：调试后知道 bindingServiceProperties 不保存绑定，因此 spring cloud stream 正在创建主题作为“输出”

Answer 1

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