文件名称：POC-kafka-messaging:使用Kafka消息代理进行异步消息传递的概念证明
文件大小：6KB
文件格式：ZIP
更新时间：2024-04-29 08:28:43
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)