python - 如何对kafka生产者进行单元测试（python）

Question

我正在使用 confluent-kafka 客户端在 kafka 集群中发送和接收消息。我有一个需要单元测试的生产者应用程序。我不想为此目的启动 Zookeeper 和 Kafka 服务器。有没有更简单的方法来使用 pytest 对其进行测试？