Merge pull request weiboad#3 from steven-hilder/suppressConnectionWar…

…nings

Suppress redundant warnings on connection failure

src/Kafka/Socket.php

@@ -165,22 +165,22 @@ public function connect()
             throw new \Kafka\Exception('Cannot open without port.');
         }
 
-        $this->stream = fsockopen(
+        $this->stream = @fsockopen(
             $this->host,
             $this->port,
             $errno,
             $errstr,
             $this->sendTimeoutSec + ($this->sendTimeoutUsec / 1000000)
         );
 
-        stream_set_blocking($this->stream, 0);
-
         if ($this->stream == false) {
             $error = 'Could not connect to '
                     . $this->host . ':' . $this->port
                     . ' ('.$errstr.' ['.$errno.'])';
             throw new \Kafka\Exception($error);
         }
+
+        stream_set_blocking($this->stream, 0);
     }
 
     // }}}