apache-kafka - 春季卡夫卡生产者和消费者的单元测试

Question

我想为 spring kafka 生产者和消费者编写单元测试。我尝试了多种方法：

1. 嵌入式Kafka注解
2. 嵌入式Kafka规则
3. 嵌入式KafkaBroker等...

每次我遇到一个或另一个错误时，GitHub 上发布的所有示例似乎都没有运行。我也检查了 spring kafka 版本的兼容性。

有人可以分享一个最近编写并成功运行的示例代码库吗？

Answer 1

框架本身有数百个测试。

这可能是最广泛的一个......

https://github.com/spring-projects/spring-kafka/blob/1b9a9451feea7cca16903f1c990c74c6be9b8ffb/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java#L164-L176