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

Question

当代理中没有数据要提取时，消费者会一直处于紧密的循环状态直到数据到达。因此，我想找到一种方法告诉消费者等待，直到经纪人有一些数据。我使用Kafka 0.9 java客户端

Answer 1

因此，基本上Kafka是基于Pull的客户端，它会继续查询服务器以确定是否有新消息，要么可以有更高的轮询间隔，要么可以使用获取概念.max.wait.ms和fetch.min.bytes，这是文档中关于fetch.min.bytes的说明 - 服务器为获取请求返回的最小数据量。如果数据不足，请求会在回复请求之前等待那么多的数据累积。