卡夫卡生产者/消费者的例子
MhUnitTest.py通过按顺序使用生产者和使用者来执行一些单元测试。 MhProducer.py包含生产者类。 MhConsumer.py包含使用者类。
要求和依赖性
您需要下载.pem,.cert和.key文件并将其放置在与源代码相同的文件夹中。 生产者使用它们与经纪人建立安全连接。
该代码是用Python 3.8编写的,并且依赖于以下模块:
sys json re time请求kafka警告psycopg2
MhUnitTest.py文件的调用约定
输入以下命令行以运行单元测试:
python MhUnitTest.py
他们将需要大约一分钟的时间来运行。 您需要将.pem,.cert和.key文件放在同一文件夹中。 这些文件可以从您在Maiven上的帐户下载。
MhProducer.py和MhConsumer.py文件的调用约定
您可以启动两