Spring Boot集成Spring Kafka测试时遇Topic not found错误求助

嘿，你遇到的这个问题很常见，并不是必须使用Embedded Kafka，这里有几个实用的解决办法，你可以根据自己的测试场景灵活选择：

1. Mock掉Kafka Streams相关组件（推荐用于纯上下文加载测试） #

因为你的测试只是验证Spring上下文能正常加载，不需要实际运行Kafka Streams拓扑，所以最简单的方式是mock掉Streams相关的bean，避免它在测试初始化时去连接Kafka并检查主题。

比如在你的测试类里添加@MockBean：

@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTest {
    // Mock掉KafkaStreams类，阻止它初始化并触发主题检查逻辑
    @MockBean
    private KafkaStreams kafkaStreams;

    @Test
    public void loadContext() throws Exception {}
}

这样Spring上下文加载时，会用mock对象替代真实的KafkaStreams实例，自然就不会出现主题找不到的报错了。

你也可以结合@Profile注解做更灵活的配置：给Kafka Streams的配置类加上@Profile("!test")，然后在测试类激活test profile，让测试环境直接跳过Streams组件的加载：

@RunWith(SpringRunner.class)
@SpringBootTest
@ActiveProfiles("test")
public class ApplicationTest {
    @Test
    public void loadContext() throws Exception {}
}

2. 让Kafka Broker自动创建主题（适合有测试环境Kafka的场景） #

如果你的测试环境有独立的Kafka Broker，可以开启Broker的自动创建主题配置，这样当Streams尝试访问不存在的主题时，Broker会自动帮你创建。

在Kafka Broker的server.properties里添加：

auto.create.topics.enable=true

不过要注意，这个配置绝对不建议在生产环境开启，但测试环境用起来会很省心。

3. 测试前手动创建主题 #

你可以在测试代码里用Kafka的AdminClient提前创建需要的主题，比如：

@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTest {

    @Before
    public void createRequiredTopics() {
        Properties adminProps = new Properties();
        adminProps.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "your-test-kafka:9092");
        try (AdminClient adminClient = AdminClient.create(adminProps)) {
            // 创建目标主题，指定分区数和副本数
            NewTopic targetTopic = new NewTopic("asd", 1, (short) 1);
            adminClient.createTopics(Collections.singleton(targetTopic)).all().get();
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }

    @Test
    public void loadContext() throws Exception {}
}

这种方式需要测试环境能正常访问Kafka Broker，并且你的测试账号有创建主题的权限。

4. 使用Embedded Kafka（备选方案） #

如果上面的方法都不适合你，Embedded Kafka也是一个靠谱的选择——它会在测试过程中启动一个嵌入式的Kafka Broker，自动帮你管理主题。

在测试类上添加@EmbeddedKafka注解并指定需要的主题：

@RunWith(SpringRunner.class)
@SpringBootTest
@EmbeddedKafka(topics = "asd")
public class ApplicationTest {
    @Test
    public void loadContext() throws Exception {}
}

记得要在项目依赖里引入spring-kafka-test模块，才能使用这个注解。

内容的提问来源于stack exchange，提问作者riccardo.cardin