1回答
我想在GO for Unit Testing中模拟融合的Kafka API for Consumer和Producer，有什么方法(流程/步骤/库)可以成功模拟它们吗？
浏览 17提问于2019-12-13得票数 7
1回答
我开发了一个消费者卡夫卡，它做了以下工作：-得到一个关于卡夫卡主题的事件。-执行一些操作-发布一个或多个关于卡夫卡主题的事件我正在寻找一种解决方案，使用Jmeter或Gateling。
浏览 0提问于2019-12-30得票数 1
1回答
我一直在寻找春天测试卡夫卡的最佳方法。据我所知，@EmbeddedKafka更适合于单元测试，但是在真正的工作环境中为Kafka编写集成测试不是更好吗？我到底在用什么测试卡夫卡的单元测试呢？一个真正工作的生产者和消费者应该比嘲笑卡夫卡更有意义。你有什么建议？
浏览 5提问于2022-03-20得票数 0
回答已采纳
librdkafka c++库有没有一个不需要启动kafka服务器就可以进行单元测试的模拟服务器？如果没有，那么有没有一个轻量级的kafka服务器可以简单易用呢？librdkafka库中的示例和单元测试是否需要kafka服务器才能运行？如果不是，它使用的是什么？我看到它列出了localhost:9092，它会在启动时启动自己的模拟代理吗？
谢谢!
浏览 0提问于2018-03-02得票数 0
我需要一些帮助来为我的Java kafka用户构建一个Junit测试用例。
我的原始源代码具有如下方法，并且需要为其创建一个Unit测试用例。我的kafka使用者正在从Kafka主题拉取消息，我需要能够提供ConsumerRecords格式的输入消息，但作为单元测试的一部分，我不会从kafka中轮询消息，而是模拟原始kafka主题中的消息，并将静态输入消息提供给<
浏览 0提问于2018-05-02得票数 2
我正在使用github.com/confluentinc/confluent-kafka-go/kafka作为一个包来处理kafka。它有像NewConsumer，SubscribeTopics，Poll这样的函数，这些函数不是使用接口声明的。我如何模拟它们进行单元测试？
浏览 1提问于2021-09-20得票数 0
2回答
在探索如何对卡夫卡流进行单元测试时，我遇到了ProcessorTopologyTestDriver，不幸的是，这个类似乎已经与版本0.10.1.0 ()分离了。注意:我确实有使用嵌入式服务器的集成
浏览 6提问于2017-04-05得票数 4
1回答
我有两个使用Kafka互相传递消息的服务。然而，对于我的集成测试，我不一定想要运行Kafka来运行我的测试。有没有一种标准的方法来模拟卡夫卡？或者这是我需要自己创建的东西，在应用程序中适当的地方创建一些MockKafka队列和补丁？此外，这是否违反了集成测试应该做的事情？我对此的看法是，我不是在测试Kafka的任何功能，在那里，为了集成测试的原因
浏览 3提问于2016-11-25得票数 6
1回答
在戈朗为卡夫卡编写单元测试的正确方法是什么？然而，我在卡夫卡找不到类似的东西。有几篇很好的文章介绍了如何使用码头容器来打开Kafka并测试E2E流。但我真的在寻找模拟服务器的单元测试。
我用的是合流卡夫卡围棋
浏览 19提问于2021-12-23得票数 0
1回答
如何进行集成测试和端到端测试？
、、、、
我们最近在我们的.NET项目中开始使用TDD方法，到目前为止我们已经完成了很好的单元测试，但是我们仍然面临着集成和端到端测试的问题。, kafka); // MOQ all the three这里我们有6个外部组件要集成到我们的应用程序中我们可以通过模拟构造函数注入中的所有依赖项来对这三个对象进行单元测试<
浏览 0提问于2018-01-17得票数 0
回答已采纳
我们需要执行我们的实时流应用程序的单元测试，它是用scala编写的。另一种选择是使用kafka连接datagen 。在各种博客上找到的例子包括CLI选项。感谢有关kafka连接datagen或模拟scala应用程序的任何优秀资源<e
浏览 4提问于2022-03-10得票数 0
最近，我对编写涵盖测试场景的好的单元测试感到好奇。我有一个这样的方法{既然我的函数依赖Redis来返回数据，我该如何编写覆盖测试用例的测试呢？因此，我的redis需要有这样的数据，然后才能继续下一步(使用system n运行创建数据，设置p_id =我在系统中创建<em
浏览 4提问于2019-07-18得票数 1
1回答
例如，一条新的“购物订单”消息到达，但我使用模拟的"Customer“对象和模拟的"item”对象来处理订单。计划是移动到使用真实的客户主题和真实的项目主题。我计划保留使用者API，即使用Spring实现来接收新的订单消息，同时使用流依赖来创建状态存储，最终替换模拟的数据。这个想法是，被模仿的数据最终将来自其他主题。因此，在这种方法中，Kafka</em
浏览 0提问于2019-02-20得票数 1
1回答
kafka集成测试用例
、、、、
我对junit测试用例非常陌生，我想为kafka集成编写junit。下面是我的代码@Configuration }在其他类中，我有一个使用kafkaTemplate将消息发送到kafka的方法
publ
浏览 8提问于2020-07-30得票数 0
我添加了flinkkafkaconsumer作为我的streamexecutionenvironment的源。我想关闭/停止flink在特定时间内没有接收到新消息时使用数据(类似于kafka polltime)。目前，它正在无限期地运行，并阻止执行移动到下一步(验证消息)。如果有什么解决办法，请建议。注意:我尝试使用反序列化的endofstream，因为流实际上是不确定的，所以它不能工作。
提前谢谢。
浏览 3提问于2019-12-05得票数 0
回答已采纳
我正在尝试为我的Spring Boot with camel routes应用程序编写单元测试。我的路由生产者是一个Kafka端点，URI是在application.properties文件中定义的。我试图模拟这个Kafka生产者端点，但它没有解析URI值。=localhost:9092我期望
浏览 10提问于2017-07-21得票数 0
回答已采纳
3回答
我们有一个消息调度器，它在将消息属性放到Kafka主题队列中之前，会根据消息属性生成一个散列键。最终，无论用于模拟Kafka队列的是什么，都应该以与本地集群相同的方式工作-即，为主题队列提供关键字插入。
有这样的工具吗？
浏览 1提问于2016-10-31得票数 10
回答已采纳
1回答
Mockito用于模拟对象以进行单元测试。使用java反射API也可以这样做。这是否意味着Mockito是在java的反射API上实现的？
浏览 2提问于2015-09-19得票数 2
回答已采纳
我有一个Camel端点，它基本上是一个Kafka消费者，从主题中读取并将信息发送到数据库。它工作得很好，但是，我正在努力对它进行单元测试，因为我还不能模拟Kafka端点。@Override from(kafka:eph?
浏览 31提问于2020-04-03得票数 1
回答已采纳
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
