From 41069e6e1d3b3b5f9d06c9aa20035d1c26775854 Mon Sep 17 00:00:00 2001
From: Rudy den Otter <rudy@keepgettingbetter.io>
Date: Fri, 10 Jan 2020 14:36:20 +0100
Subject: [PATCH] Catch consume error "Local: Broker transport failure" and
 continue consuming

---
 pkg/rdkafka/RdKafkaConsumer.php | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pkg/rdkafka/RdKafkaConsumer.php b/pkg/rdkafka/RdKafkaConsumer.php
index 88b05adac..6ec89aaf5 100644
--- a/pkg/rdkafka/RdKafkaConsumer.php
+++ b/pkg/rdkafka/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);