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

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 运行