【文件属性】：
文件名称：POC-kafka-messaging:使用Kafka消息代理进行异步消息传递的概念证明
文件大小：6KB
文件格式：ZIP
更新时间：2021-04-09 14:42:03
Python
Kafka异步消息传递POC
该项目的目标是为使用Kafka作为消息代理的小型消费者/生产者异步事件驱动的通信创建概念证明。 Kafka将集合中的事件持久化并准备好以分离，可升级，可靠和有弹性的方式供服务使用（面向服务的体系结构）。
卡夫卡及其好处的简要介绍： :
安装和设置过程
为了运行此POC，需要安装Python3.7运行时。 还需要安装docker才能在本地运行kafka broker，以进行测试。
py -m pip install -r requirements.txt
docker-compose up
py consumer.py
py producer.py
在这一点上，您应该看到使用者处理的消息。
POC实施细节
在此示例中，为了简单起见，我们使用Kafka本身带来的默认主题（这是default_ksql_processing_log ）
下一步
最后
【文件预览】：
POC-kafka-messaging-master
----.gitignore(2KB)
----consumer.py(1KB)
----requirements.txt(19B)
----producer.py(2KB)
----docker-compose.yml(6KB)
----README.md(2KB)