为Kafka Spring编写集成或单元测试更好吗？
我一直在寻找Spring测试Kafka的最佳方法。据我所知，@EmbeddedKafka更适合于单元测试，但在真实的工作环境中为它编写集成测试不是更好吗？通过为Kafka编写单元测试，我到底在测试什么？一个真正的生产者和消费者应该比嘲笑Kafka更有意义。你有什么建议？
共有1个答案
EmbeddedKafka是一种集成测试。它启动了一个真正的经纪人，而不是一个模拟的经纪人，让你与之互动。
对于单元测试，Kafka为消费者和生产者提供了自己的模拟，而不依赖于Spring库
我通过为Kafka编写单元测试来测试什么
您的一般处理逻辑，包括错误处理和反序列化
在Kafka Streams中，您还可以控制记录的计时，以便基于模拟窗口测试聚合逻辑
-
我不会告诉你有关后台任务的单元测试的任何内容，因为Hangfire没有添加任何特定方法 (除了 IJobCancellationToken 接口参数)去改变任务。使用您最喜爱的工具，并照常写入单元测试。本节介绍如何测试创建的后台任务。 所有的代码示例都使用静态 BackgroundJob 类来告诉你如何做这个或那些东西，只是出于简单演示的目的。但是当你想测试调用的静态方法时，会变得很痛苦。 不用担
-
单元测试 单元测试仅依赖于源代码，是测试代码逻辑是否符合预期的最简单方法。 运行所有的单元测试 make test 仅测试指定的package # 单个package make test WHAT=./pkg/api # 多个packages make test WHAT=./pkg/{api,kubelet} 或者，也可以直接用go test go test -v k8s.io/kubernet
-
试图弄清楚我是否可以使用spring kafka和spring kafka测试为@KafkaListener编写单元测试。 我的听众课。 我的测试类别： 我的测试配置类： 有什么简单的方法可以做到这一点吗？ 或者我应该以其他方式测试@KafkaListener？在单元测试中，如何确保在Kafka中收到新消息时调用@KafkaListener。
-
我在java中使用mockito编写单元测试。 这就是我要测试的声明。 电影是电影名称的集合，是识别电影的关键。 我嘲笑了守望者班 Mockito.when（watcher.watch（Matchers.any（Set.class））） “thenReturn”中包括什么？？
-
我想为上面的内容编写单元测试，以测试我正在使用的注释的sampleURL，比如如果我给出任何应该与regex模式匹配的URL。我浏览了以下链接：如何在spring中进行单元测试验证注释，如何使用JUnit测试类的验证注释？但它们没有多大帮助，我也有setSampleURL函数。那么，如何为sampleURL变量编写测试呢。基本上，我想为regex模式编写测试，即我给sampleURL的值是否与re
-
问题内容： 我有一个Java课。如何进行 单元测试？ 就我而言，我有课做一个二进制和。它需要两个数组，将它们求和，然后返回一个新的二进制数组。 问题答案： 使用正确的输入定义正常情况下的预期和期望输出。 现在，通过声明一个类来实现测试，将其命名为任何东西（通常是类似TestAddingModule之类的东西），并向其添加testAdd方法（即，类似于下面的方法）： 编写一个方法，并在其上方添加@T