卡夫卡

【文件属性】：
文件名称：卡夫卡
文件大小：1KB
文件格式：ZIP
更新时间：2021-03-04 03:27:36
卡夫卡生产者/消费者的例子 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文件的调用约定 您可以启动两

【文件预览】：
Kafka-main
----README.md(3KB)