From d2df5af97a1defd15f94386a119f59ec1b970b6d Mon Sep 17 00:00:00 2001 From: nmred Date: Wed, 10 May 2017 03:56:25 +0000 Subject: [PATCH] fixed issue #97 --- src/Kafka/Socket.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Kafka/Socket.php b/src/Kafka/Socket.php index e2a0d667..d43cd146 100644 --- 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);