测试之间的嵌入式 Kafka 刷新消息

Question

我使用 Spring Kafka 和注释@EmbeddedKafka来启动嵌入式 kafka 实例。

依赖关系：

<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka-test</artifactId>
  <scope>test</scope>
</dependency>

我已经配置了我的应用程序以连接到它：

spring:
  kafka:
    bootstrap-servers: ${spring.embedded.kafka.brokers}

我成功发送消息并消费消息。

我的问题是这些消息保留在某处，并且可能会出现在正在进行的测试运行中。日志正在打印这些：

Successfully joined group with generation 117

高代数表明 Kafka 在测试重新运行之间保留了我不想要的信息。

如何彻底清理嵌入式 Kafka 并重新开始？

编辑：

我遇到的问题是我错误地使用了 Spring Profiles。我有一个带有嵌入式 Kafka 配置的自定义注释注释。问题是我@ActiveProfiles("kafka")在复合注释中设置，也在@ActiveProfiles("dev")实际的测试类中设置。我已将复合注释更新为：

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
// @ActiveProfiles("kafka") REMOVED
@TestPropertySource(properties = "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}")
@EmbeddedKafka(/* config properties */)
public @interface CustomEmbeddedKafka{
}

Answer 1

您需要@DirtiesContext在测试之间清理应用程序上下文。与此同时，嵌入式 Kafka 代理也将被摧毁。

如果问题出在一个测试类方法之间，那么您需要重新考虑那里的逻辑，不要干扰不同方法中的相同主题。

您也可以考虑使用@DirtiesContext(classMode = DirtiesContext.ClassMode.BEFORE_EACH_TEST_METHOD)，但这会导致某种性能下降，因为在每个测试方法之前都会重新创建应用程序上下文和嵌入式 Kafka。

更新

尝试这个建议而不是application.properties修改：

static {
    System.setProperty(EmbeddedKafkaBroker.BROKER_LIST_PROPERTY,
            "spring.kafka.bootstrap-servers");
}

请参阅https://docs.spring.io/spring-kafka/docs/2.2.5.RELEASE/reference/#kafka-testing-embeddedkafka-annotation