Merge pull request #842 from Steveb-p/master

[Kafka] Fix consumption errors in kafka against recent versions in librdkafka/phprdkafka

Author: makasim

pkg/rdkafka/RdKafkaConsumer.php

@@ -155,6 +155,10 @@ private function doReceive(int $timeout): ?RdKafkaMessage
     {
         $kafkaMessage = $this->consumer->consume($timeout);
 
+        if (null === $kafkaMessage) {
+            return null;
+        }
+
         switch ($kafkaMessage->err) {
             case RD_KAFKA_RESP_ERR__PARTITION_EOF:
             case RD_KAFKA_RESP_ERR__TIMED_OUT: