kafka-sse-example:通过HTTP流API公开Kafka消息

【文件属性】：

文件名称：kafka-sse-example:通过HTTP流API公开Kafka消息

文件大小：9KB

文件格式：ZIP

更新时间：2024-05-30 14:44:49

Python

Kafka SSE示例 该示例项目从服务读取消息，并使用服务器发送事件（SSE）协议通过HTTP流API公开数据。 它使用Python和Django编写，并依靠来管理流连接。 设置和使用 设置virtualenv并安装依赖项： virtualenv --python=python3 venv . venv/bin/activate pip install -r requirements.txt 使用Kafka和图钉设置创建合适的.env ： KAFKA_CONSUMER_CONFIG={ " bootstrap.servers " : " localhost:9092 " , " group.id " : " mygroup " } GRIP_URL=http://localhost:5561 运行Django服务器： python manage.py runserver 运行

【文件预览】：
kafka-sse-example-master
----.gitignore(35B)
----README.md(2KB)
----manage.py(845B)
----kafka_events()
--------admin.py(63B)
--------models.py(57B)
--------migrations()
--------urls.py(126B)
--------tests.py(60B)
--------__init__.py(0B)
--------apps.py(98B)
--------management()
--------views.py(194B)
----server()
--------settings.py(3KB)
--------urls.py(105B)
--------__init__.py(0B)
--------wsgi.py(390B)
----requirements.txt(77B)