Merge pull request #196 from simPod/connection-exception

Connection Exception

Author: nmred

src/Consumer/Process.php

@@ -231,9 +231,7 @@ protected function syncMeta(): void
             return;
         }
 
-        throw new Exception(
-            sprintf('It was not possible to establish a connection for metadata with the brokers "%s"', $brokerList)
-        );
+        throw Exception\ConnectionException::fromBrokerList($brokerList);
     }
 
     protected function getGroupBrokerId(): void

src/Exception/ConnectionException.php

@@ -0,0 +1,20 @@
+<?php
+declare(strict_types=1);
+
+namespace Kafka\Exception;
+
+use Kafka\Exception;
+use function sprintf;
+
+final class ConnectionException extends Exception
+{
+    public static function fromBrokerList(string $brokerList): self
+    {
+        return new self(
+            sprintf(
+                'It was not possible to establish a connection for metadata with the brokers "%s"',
+                $brokerList
+            )
+        );
+    }
+}

src/Producer/Process.php

@@ -167,12 +167,7 @@ public function syncMeta(): void
             }
         }
 
-        throw new Exception(
-            sprintf(
-                'It was not possible to establish a connection for metadata with the brokers "%s"',
-                $brokerList
-            )
-        );
+        throw Exception\ConnectionException::fromBrokerList($brokerList);
     }
 
     /**

src/Producer/SyncProcess.php

@@ -14,7 +14,6 @@
 use function explode;
 use function json_encode;
 use function shuffle;
-use function sprintf;
 use function substr;
 use function trim;
 
@@ -144,12 +143,7 @@ public function syncMeta(): void
             return;
         }
 
-        throw new Exception(
-            sprintf(
-                'It was not possible to establish a connection for metadata with the brokers "%s"',
-                $brokerList
-            )
-        );
+        throw Exception\ConnectionException::fromBrokerList($brokerList);
     }
 
     /**