一个易于使用的kafka消费者,它扩展了kafka python,但遵循flask服务器的风格
kafkaesque的Python项目详细描述
#卡夫卡式消费品。它是kafka python包中kafka consumer的一个扩展,kafka python包可用[`here`](https://github.com/dpkp/kafka-python)
/>
app=kafkaesque(
bootstrap_servers=",".join([
"bs_1:9092",
"bs_2:9093",
"bs_3:9094"
],
group_id="consumer grp id"
)
@app.handle('test-topic')
def test_topic处理程序(msg):
打印"Consumed{}from test topic"(从测试主题中消费的{})。如果u name_uuu=="main_uu":
app.start()
`````
**sankalp jonna**
/>
app=kafkaesque(
bootstrap_servers=",".join([
"bs_1:9092",
"bs_2:9093",
"bs_3:9094"
],
group_id="consumer grp id"
)
@app.handle('test-topic')
def test_topic处理程序(msg):
打印"Consumed{}from test topic"(从测试主题中消费的{})。如果u name_uuu=="main_uu":
app.start()
`````