php - 如何在 php 中设置连续的 kafka 消费者，而不会出现连接超时

Question

我正在使用以下代码从 kafka 读取消息。但是要设置消费者，我必须给出连接超时。就我而言，我想要一个持续阅读的消费者，我无法设置连接超时，因为有时它可能不会从很长时间内收到任何消息。我如何处理它。

while (true) { 
    $message = $topic->consume(0, 1200);  //120*10000);
    if(isset($message->err)){
        switch ($message->err) {
            case RD_KAFKA_RESP_ERR_NO_ERROR:
            break;
            case RD_KAFKA_RESP_ERR__TIMED_OUT
            break;
            default:
            break;
        }

}