【文件属性】：
文件名称：kafka-sse-example:通过HTTP流API公开Kafka消息
文件大小：9KB
文件格式：ZIP
更新时间：2021-05-10 20:58:09
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)