kafka消费者轮询超时

Question

我正在使用 Kafka 并尝试从中获取数据。从下面一行，我可以轮询来自 Kafka 的数据。

  while (true) {
    ConsumerRecords<byte[], <byte[]> records = consumer.poll(Long.MAX_VALUE);
    for (ConsumerRecord<byte[], <byte[]> record : records) {
        // retrieve data
    }
  }

我的问题是，与提供200 作为超时相比，提供Long.MAX_VALUE 作为超时有什么好处。将运行生产的系统的最佳实践是什么。

谁能解释一下高超时和低超时的区别，哪些应该在生产系统中使用？

Answer 1

设置 MAX_VALUE 是一种同步消息消耗，永远等待直到我们从轮询中返回一些东西，而设置为较低的值让您有机会决定做其他事情而不是等待。应该使用哪个取决于您的实际情况。