flasfka:Flask 应用程序通过 HTTP 在 Kafka 上进行推拉

弗拉夫卡 通过 HTTP 在 Kafka 上推/拉 安装 您可以使用 pip 安装 kafka： pip install kafka 或者，您可以构建和使用。 配置 要设置 flasfka 以与 Kafka 集群通信，可以使用以下变量。 把它放在一个文件中（例如/etc/flasfka.conf.py ）： # Hosts in the kafka cluster (list of ip:port) HOSTS=["localhost:9092"] # You probably don't need to change these # How long to wait when polling a topic for new messages CONSUMER_TIMEOUT=0.1 # Maximum of messages returned when consuming from