我有一个需要单元测试的producer应用程序。我不想为了这个目的而启动zookeeper和kafka服务器。有没有更简单的方法用mockito来测试它？
knpiaxh11#
如果您不想启动kafka和zookeeper，可以使用kafka附带的模拟客户端来模拟从kafka集群发送和接收消息：模拟制作人：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/producer/mockproducer.html模拟消费者：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/consumer/mockconsumer.html
6mw9ycah2#
对于这样的测试，我使用了SpringKafka测试库中的embeddedkafka（尽管我的应用程序中没有使用spring，但事实证明这是设置单元测试的最简单方法）。举个例子：https://www.codenotfound.com/spring-kafka-embedded-unit-test-example.html事实上，Kafka和Zookeeper在同一个过程中为你旋转，所以你不是真的嘲弄什么，所以你不需要嘲弄。我用的是纯junit。
2条答案
按热度按时间knpiaxh11#
如果您不想启动kafka和zookeeper，可以使用kafka附带的模拟客户端来模拟从kafka集群发送和接收消息：
模拟制作人：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/producer/mockproducer.html
模拟消费者：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/consumer/mockconsumer.html
6mw9ycah2#
对于这样的测试，我使用了SpringKafka测试库中的embeddedkafka（尽管我的应用程序中没有使用spring，但事实证明这是设置单元测试的最简单方法）。举个例子：https://www.codenotfound.com/spring-kafka-embedded-unit-test-example.html
事实上，Kafka和Zookeeper在同一个过程中为你旋转，所以你不是真的嘲弄什么，所以你不需要嘲弄。我用的是纯junit。