java - 消费者属性 spring cloud 和 kafka binder

Question

我有一个使用 Spring Cloud 的 Spring 应用程序。我使用 kafka binder，我正在尝试修改消费者的主题属性所以我在 application.yaml 中使用这个 cde

spring.cloud.bindings.my-input-in-0.destination: some-topic
spring.cloud.kafka.bindings.my-input-in-0.consumer.topic.properties.cleanup.policy: compact

该代码创建了主题，但 clean.policy 始终被删除，它忽略了紧凑配置。

但是，如果我对生产者绑定做同样的事情，则可以正常工作：

spring.cloud.bindings.my-input-out-0.destination: some-topic
spring.cloud.kafka.bindings.my-input-out-0.producer.topic.properties.cleanup.policy: compact

不知道为什么我不能在具有策略契约的消费者中自动创建主题

标签： javaspringapache-kafkaspring-cloudspring-cloud-stream