Merge pull request #1 from ClamorousKun/master

修复连接超时时message返回空的问题感谢@ClamorousKun 帮助修复
wenzhenxi · Apr 1, 2017 · 326b288 · 326b288
2 parents 5917f1b + 6dcbf57
commit 326b288
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/Consumer.php b/Consumer.php
@@ -83,6 +83,11 @@ public function consumerStop() {
      */
     public function consume() {
         $message = $this->topic->consume($this->partition, $this->timeout * 1000);
+
+	if (empty($message)) {
+	    return null;
+	}
+
         switch ($message->err) {
             case RD_KAFKA_RESP_ERR_NO_ERROR:
                 return $message;