如何对kafka producer(python)进行单元测试

2024-05-23 22:24:26 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在使用confluent kafka客户端在kafka集群中发送和接收消息。我有一个需要单元测试的生产者应用程序。我不想为了这个目的启动动物园管理员和卡夫卡服务器。有没有更简单的方法使用pytest来测试它


Tags: kafka方法目的服务器应用程序消息客户端pytest