spring kafka 生产者和消费者的单元测试

如何解决spring kafka 生产者和消费者的单元测试

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

1. 嵌入式Kafka注解
2. 嵌入式KafkaRule
3. 嵌入式Kafkabroker 等等...

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

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

解决方法

framework itself 中有数百个测试。

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

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