Kafka：是否有使用 Mockito 对 Kafka 进行单元测试的示例？

Question

我有一个需要单元测试的生产者应用程序。我不想为此目的启动 Zookeeper 和 Kafka 服务器。有没有更简单的方法来使用 Mockito 测试它？

Answer 1

如果不想启动 Kafka 和 Zookeeper，可以使用 Kafka 自带的 Mock 客户端来伪造从 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