Kafka生产者集成测试定义

Question

我有一个应用程序代码，产生一个卡夫卡主题的事件。所以现在我需要为它编写集成测试。在网上搜索后，我对集成测试的定义感到困惑，我是应该使用spring-kafka-test库提供的嵌入式Kafka服务器，还是应该使用将要使用的实际Kafka集群来测试我的代码？

这里的集成测试是什么？有没有人能帮我澄清一下。

我的测试是:首先生成一个主题的记录，然后使用它，无论它是否实际生成。

Answer 1

每个项目可能有不同的需求，这就是为什么每个开发人员可能会认为某些东西是足够的或不够的。

更完整(但昂贵)的测试套件将：

1. 隔离测试生产者
2. 测试a嵌入了kafka的生产者
3. 测试具有测试配置(单节点，本地)的kafka实例的生产者
4. 在Staging environment (多节点，在实际服务器中，但在“测试环境”中，作为CI/CD测试)使用具有生产配置的kafka测试生产者在实际生产中对生产服务器进行压力测试，并确保产品运行良好(请考虑Simian Army)

这到底值多少钱，取决于你：

• 我会做1，因为TDD
• 3也很便宜，使2成为多余的，并向您保证实际的“集成”正在工作我总是做3。
• 4对于生产中的任何产品都是必要的且常见的，它在3的基础上是自动化的。
• 5只有几家公司实现，在您的实际生产环境中“攻击你自己”实际上需要花费大量的钱，仅仅是为了确保一切都正常工作。

每个is测试层都与您赋予它的重要性一样重要，并且可能看起来像是“覆盖”，因为某些bug只出现在下一层。