一个易于使用的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 OutOfMemoryError以及如何使运行继续   java树映射内存使用率   使用带有java spark的javascript获取api的挂起承诺状态(POST请求)   java Android:存储用户单击的CardView   输入了有关拖动的java信息   单元测试中的java DecimalFormat(“·#,##0”)前缀   来自客户端的java超时webservice调用   java未使用的超类变量   如何在Java中的参数提示中强制执行整数限制   启动期间Tomcat中出现java错误:找不到DB名称   java Marshall/Unmarshall地图   一个类在另一个类中的java访问变量   如何在java中对字符数组的文本进行对齐?   从jenkins运行时,使用selenium上传excel文件的java不起作用   java将double转换为BigInteger   java Android键盘问题与按键释放   旋转java在两个旋转矩形之间的碰撞检测   在TestNG中执行时,XML中出现java启动错误无法继续执行测试