为 Kafka Spring 编写集成或单元测试更好吗?

Is it better to write integration or unit test for Kafka Spring?

我一直在寻找在 Spring 中测试 Kafka 的最佳方法。 据我所知,@EmbeddedKafka 更适合单元测试,但通过为其编写集成测试在真实工作环境中测试 Kafka 不是更好吗? 通过为 Kafka 编写单元测试,我到底在测试什么? 一个真正工作的生产者和消费者应该比嘲笑卡夫卡更有意义。 你有什么建议?

EmbeddedKafka 集成测试。它启动了一个真正的经纪人,而不是模拟的,供您与之互动。

对于单元测试,Kafka 为消费者和生产者提供了自己的模拟,不依赖于 Spring 库

what really am I testing by writing unit test for Kafka

您的一般处理逻辑,包括错误处理和反序列化

在Kafka Streams中,还可以根据模拟windows

控制测试聚合逻辑的记录时序