时间戳

首页 > 解决方案 > 为什么 Kafka ConsumerNetworkClient.poll() 使用锁？

apache-kafka - 为什么 Kafka ConsumerNetworkClient.poll() 使用锁？

问题描述

最近看kafka-clients-2.7.0源码，发现ConsumerNetworkClient.poll(Timer timer, PollCondition pollCondition, boolean disableWakeup) 使用锁来轮询消息。我不明白为什么要这样设计。
巧合的是，我只看到https://cwiki.apache.org/confluence/display/KAFKA/KIP-62%3A+Allow+consumer+to+send+heartbeats+from+a+background+thread。它是为解决会话超时而设计的吗？

有点乱，希望有大神指点一下，谢谢！

标签： apache-kafka

解决方案

推荐阅读