如何解决KafkaCompanion中的TopicExistsException异常

嘿，我之前把单元测试从KafkaBroker迁移到KafkaCompanion的时候，也踩过这个TopicExists的坑！给你几个实用的解决办法，应该能彻底搞定这个问题：

首先得说清问题根源：单元测试的执行是互相独立的，但KafkaCompanion默认不会自动清理上一个测试用例创建的主题，所以下一个测试再尝试创建同名主题时，就会抛出这个报错：

TopicExists — Topic my-topic-events already exists.

接下来是具体的解决思路：

• 提前清理+重建主题（最直接的方案）
  你已经想到在@BeforeEach里做初始化了，我把这个思路补全成可运行的代码逻辑。每次测试开始前，先检查目标主题是否存在，存在就删除，等删除完成后再重建：

  @SneakyThrows
  private void cleanAndRecreateTopic() {
      // 1. 检查主题是否已存在
      Collection<TopicListing> existingTopics = kafkaCompanion.admin().listTopics().listings().get();
      boolean isTopicExists = existingTopics.stream()
          .anyMatch(topic -> topic.name().equals("my-topic-events"));
      
      // 2. 如果存在则删除，等待删除完成
      if (isTopicExists) {
          kafkaCompanion.admin().deleteTopics(Collections.singletonList("my-topic-events")).all().get();
          // 这里可以用轮询代替sleep，更优雅：比如循环检查主题是否消失，最多等3秒
          Thread.sleep(1000);
      }
      
      // 3. 重建主题，替换成你实际的主题配置
      NewTopic targetTopic = TopicBuilder.name("my-topic-events")
          .partitions(1)
          .replicationFactor((short) 1)
          .build();
      kafkaCompanion.admin().createTopics(Collections.singletonList(targetTopic)).all().get();
  }
  

  把这个方法标注上@BeforeEach，每次测试前都会自动执行，保证主题是全新的状态。

• 测试结束后清理主题
  另一种思路是在每个测试结束后（@AfterEach）删除主题，这样下一个测试启动时，主题已经不存在了。代码逻辑和上面的删除部分一致，只是把方法放在@AfterEach注解下，适合不需要保留测试后主题数据的场景。

• 使用唯一主题名（避免冲突）
  如果你不想频繁删除重建，可以给每个测试用例的主题名加个随机后缀或者测试用例名称前缀，比如：

  private String getUniqueTopicName() {
      return "my-topic-events-" + UUID.randomUUID().toString().substring(0, 8);
  }
  

  这样每个测试用的主题都是唯一的，自然不会有已存在的问题，不过这种方式会占用更多资源，测试结束后记得批量清理这些临时主题。

最后提醒下：处理Kafka的AdminClient操作时，一定要用get()或者其他同步方式等待操作完成，不然异步操作还没执行完，测试就开始了，还是会碰到主题存在的报错。

备注：内容来源于stack exchange，提问作者sonia belhadj