From 031686c33a907d763ccb292517540da03aa8e554 Mon Sep 17 00:00:00 2001 From: Rudy den Otter Date: Fri, 10 Jan 2020 13:28:34 +0100 Subject: [PATCH] Catch Local: Broker transport failure and continue consuming --- RdKafkaConsumer.php | 1 + 1 file changed, 1 insertion(+) diff --git a/RdKafkaConsumer.php b/RdKafkaConsumer.php index 88b05ad..6ec89aa 100644 --- a/RdKafkaConsumer.php +++ b/RdKafkaConsumer.php @@ -161,6 +161,7 @@ private function doReceive(int $timeout): ?RdKafkaMessage switch ($kafkaMessage->err) { case RD_KAFKA_RESP_ERR__PARTITION_EOF: case RD_KAFKA_RESP_ERR__TIMED_OUT: + case RD_KAFKA_RESP_ERR__TRANSPORT: return null; case RD_KAFKA_RESP_ERR_NO_ERROR: $message = $this->serializer->toMessage($kafkaMessage->payload);