Catch consume error "Local: Broker transport failure" and continue consuming

Author: Rudy den Otter

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