fixed issue #97

weiboad · May 10, 2017 · d2df5af · d2df5af
1 parent 56704d9
commit d2df5af
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Kafka/Socket.php b/src/Kafka/Socket.php
@@ -239,7 +239,7 @@ public function connect()
             $error = 'Could not connect to '
                     . $this->host . ':' . $this->port
                     . ' ('.$errstr.' ['.$errno.'])';
-            throw new \Kafka\Exception\SocketConnect($error);
+            throw new \Kafka\Exception($error);
         }
 
         stream_set_blocking($this->stream, 0);