一个易于使用的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**

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java如何定制springdata存储库方法名称?   html有没有办法将java应用程序或JApplet嵌入到网站中?   Jackson ObjectMapper将java从字符串序列化为JSON作为namevalue   java刷新JTable?   用Java程序分发用JavaDB制作的数据库   java Android如何启动新活动   当集合大小超过500.000时,java的处理速度会显著降低   在java的分层目录中的多个目录中查找相同的文件   java如何将ArrayList数据插入数据库   java如何修改此代码,使其时间复杂度为o(logn)或o(n),而不是o(n^2)   java面板(SimplePanel)中仅显示图像的前1/3(大约),   jakarta ee Java Bean和企业Java Bean之间的区别?   创建AWS Cloudfront自签名URL(java sdk)时出现amazon web服务错误   基于Jersey和Jackson查询参数的java动态属性过滤