我无法从文档中弄清楚哪个属性现在替换consumer.timeout.ms = -1(默认(，该属性在0.9之前可在kafka消费者API版本中使用。有人有新文档的链接吗？
我寻找Kafka文档，但没有成功。
Java消费者中没有明显的对应物，因为新消费者是非障碍物。在Scala消费者中，此配置控制消费者迭代器是否阻止。默认情况下，它们正在阻止。如果该配置的值设置为零，则它们变为非阻滞。与在新消费者中返回的空记录集(如poll(不同，当等待时间过去时，旧的消费者会引发异常。
如果您仍然想找出替换，我认为这将是kafkaconsumer.poll方法中的超时参数。但是，就像我上面所说的那样，Poll在超时时不会引发例外。