最近在写kafka,参考了很多博客,由于英文水平太烂,只看很小一部分英文文档.其中有管消费者端的代码编写有个疑问.我看文章大多数是用在whle(true)中遍历ConsumerRecord,while(true)应该是有很多弊端的,大家有没有其他的方法.比如其他消息队列采用的事件监听类型,或者更好的处理方式,还请大家多多交流.这个问题困惑了好久.
kafka采用的是长轮询的方式做的,进行阻塞,直到数据到达。这种是相对最优的方式了。
长轮询在while中。当一次阻塞拿到数据之后,处理完成,再次while进行长轮询。是这样的。
谢谢答复,最近重新看了下文档,发现自己没有仔细看这个问题,文档里有说明这个模式
你的答案