kafka有非阻塞式收数据的方法吗

JasperHa 发布于 2015/05/21 18:58
阅读 512
收藏 0

如题, 主要是写spout的时候阻塞接收貌似就执行不了fail和ack方法了

加载中
0
gongweixin
gongweixin
听说是不支持, 楼主了解到的情况呢?
0
gongweixin
gongweixin

引用来自“gongweixin”的评论

听说是不支持, 楼主了解到的情况呢?
我找到解决方案了,可以设置超时时长,超时没获取新message,会抛出超时异常
0
J
JasperHa
是kafka的高级api能设置超时时间?
返回顶部
顶部