Spring Boot Kafka契约测试报错：无法分配嵌入式Topic分区

一、指定@EmbeddedKafka(topics)时启动失败的原因 #

你配置的spring.kafka.topics.default.replication-factor、partition-count等参数是给KafkaAdmin组件使用的，用于生产环境自动创建Topic时的默认规则。但测试场景下，同时使用@EmbeddedKafka(topics = {"abc.abc.topic"})和这些配置会触发冲突：

• @EmbeddedKafka初始化时会优先创建指定Topic，默认采用1个分区、1个副本的配置。
• 随后KafkaAdmin会根据你配置的partition-count=3尝试创建同名Topic，但此时Topic已存在且分区数不匹配，导致Kafka内部元数据不一致，最终引发Listener无法分配分区的IllegalStateException，导致ApplicationContext加载失败。

二、移除topics参数后出现大量警告的原因 #

移除topics参数后，@EmbeddedKafka不会提前创建abc.abc.topic。而你的spring.kafka.topics.default.*只是KafkaAdmin创建Topic的默认规则，并没有显式指定要创建abc.abc.topic，因此KafkaAdmin也不会主动生成该Topic。
Listener启动时尝试订阅不存在的abc.abc.topic，Kafka会输出UNKNOWN_TOPIC_OR_PARTITION警告，直到后续测试代码发送消息时，才会依赖Kafka默认的auto.create.topics.enable=true参数自动创建Topic。

内容的提问来源于stack exchange，提问作者Ray