Как установить непрерывного потребителя кафки в php, без времени ожидания соединения

Question

Я использую следующий код для чтения сообщения от Кафки. Но чтобы установить потребителя, я должен указать время ожидания соединения. В моем случае я хочу потребителя непрерывного чтения, я не могу установить время ожидания соединения, потому что некоторое время он может не получить никакого сообщения в течение долгого времени. Как я справлюсь с этим.

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;
        }

}