Spring Cloud Kafka Streams自动主题创建配置失效问题求助

根据你的描述，已经在Broker和Spring Cloud Stream Binder层面禁用了自动主题创建，但输入主题仍被自动创建，这是因为Kafka Streams客户端有自己独立的配置参数，你之前的配置没有覆盖到Streams的核心设置。

问题根源 #

你当前配置的spring.cloud.stream.kafka.binder.consumer-properties.allow.auto.create.topics=false是针对普通Kafka消费者的，而Kafka Streams作为特殊的客户端，需要通过专门的Streams配置前缀来传递参数。在你使用的Spring Cloud版本（2020.0.3）中，Streams的初始化逻辑会独立检查输入主题状态，默认使用allow.auto.create.topics=true，这会绕过你设置的普通binder配置。

解决方案 #

在application.properties中添加针对Kafka Streams的专属配置，明确禁用自动主题创建：

# 针对Kafka Streams客户端禁用自动主题创建
spring.cloud.stream.kafka.streams.binder.configuration.allow.auto.create.topics=false

同时保留你现有的其他配置：

spring.cloud.stream.kafka.binder.autoCreateTopics=false
spring.cloud.stream.kafka.binder.autoAddPartitions=false
# Broker端已设置auto.create.topics.enable=false，无需重复配置

验证效果 #

添加上述配置后重启应用：

• 如果exampleInput主题不存在，应用会抛出TopicAuthorizationException或UnknownTopicOrPartitionException（取决于Broker权限配置），而不是自动创建主题，符合你的预期。
• 输出主题exampleOutput只有在应用尝试写入数据时才会触发检查，此时也不会自动创建，会抛出相应异常。

额外说明 #

Kafka Streams的allow.auto.create.topics参数优先级高于Broker端的auto.create.topics.enable，所以必须显式在Streams配置中设置为false，才能完全禁用自动创建行为。

内容的提问来源于stack exchange，提问作者Adam Żurada