【发布时间】：2019-05-22 08:48:24
【问题描述】：
我无法从文档中找出哪个属性现在替换了 0.9 之前的 Kafka Consumer API 版本中可用的 consumer.timeout.ms =-1（默认）。有人有新文档的链接吗？
我查找了 Kafka 文档，但没有成功。
【问题讨论】：
标签： apache-kafka kafka-consumer-api
【发布时间】：2019-05-22 08:48:24
【问题描述】：
在 java 消费者中没有明显的对应物，因为新的消费者是非阻塞的。在 Scala 消费者中，此配置控制消费者迭代器是否阻塞。默认情况下，它们是阻塞的。如果此配置的值设置为大于零，则它们将变为非阻塞。与在新消费者中返回空记录集（如 poll）不同，旧消费者在获取任何记录之前的等待时间过去时会引发异常。
如果你还想找到一个替代品，我认为它会是 KafkaConsumer.poll 方法中的超时参数。但是，就像我上面所说的，poll 在超时时不会抛出异常。
【讨论】：