如何在kafka消费者中阻止拉取请求

Question

当 broker 中没有数据可取时，consumer 保持紧密循环直到数据到达。因此，我想找到一种方法告诉消费者等到经纪人有一些数据。我正在使用 Kafka 0.9 java 客户端

Answer 1

所以基本上 Kafka 是基于 Pull 的客户端，它会不断查询服务器以确定是否有新消息，要么你可以有更高的轮询间隔，要么你可以使用 fetch.max.wait.ms 和 [= 的概念13=]，这是文档中关于 fetch.min.bytes 的内容 - 服务器应该 return 获取请求的最小数据量。如果可用数据不足，请求将等待积累足够多的数据，然后再回答请求。