[dsn] replace xxx:// to xxx:

Author: makasim

RdKafkaConnectionFactory.php

@@ -29,13 +29,13 @@ class RdKafkaConnectionFactory implements PsrConnectionFactory
      *
      * or
      *
-     * rdkafka://host:port
+     * kafka://host:port
      *
      * @param array|string $config
      */
-    public function __construct($config = 'rdkafka://')
+    public function __construct($config = 'kafka:')
     {
-        if (empty($config) || 'rdkafka://' === $config) {
+        if (empty($config) || 'kafka:' === $config) {
             $config = [];
         } elseif (is_string($config)) {
             $config = $this->parseDsn($config);
@@ -79,8 +79,8 @@ private function parseDsn($dsn)
             'query' => null,
         ], $dsnConfig);
 
-        if ('rdkafka' !== $dsnConfig['scheme']) {
-            throw new \LogicException(sprintf('The given DSN scheme "%s" is not supported. Could be "rdkafka" only.', $dsnConfig['scheme']));
+        if ('kafka' !== $dsnConfig['scheme']) {
+            throw new \LogicException(sprintf('The given DSN scheme "%s" is not supported. Could be "kafka" only.', $dsnConfig['scheme']));
         }
 
         $config = [];

Tests/RdKafkaConnectionFactoryTest.php

@@ -18,17 +18,17 @@ public function testThrowNeitherArrayStringNorNullGivenAsConfig()
     public function testThrowIfSchemeIsNotBeanstalkAmqp()
     {
         $this->expectException(\LogicException::class);
-        $this->expectExceptionMessage('The given DSN scheme "http" is not supported. Could be "rdkafka" only.');
+        $this->expectExceptionMessage('The given DSN scheme "http" is not supported. Could be "kafka" only.');
 
         new RdKafkaConnectionFactory('http://example.com');
     }
 
     public function testThrowIfDsnCouldNotBeParsed()
     {
         $this->expectException(\LogicException::class);
-        $this->expectExceptionMessage('Failed to parse DSN "rdkafka://:@/"');
+        $this->expectExceptionMessage('Failed to parse DSN "kafka://:@/"');
 
-        new RdKafkaConnectionFactory('rdkafka://:@/');
+        new RdKafkaConnectionFactory('kafka://:@/');
     }
 
     public function testShouldBeExpectedDefaultConfig()
@@ -50,7 +50,7 @@ public function testShouldBeExpectedDefaultConfig()
 
     public function testShouldBeExpectedDefaultDsnConfig()
     {
-        $factory = new RdKafkaConnectionFactory('rdkafka://');
+        $factory = new RdKafkaConnectionFactory('kafka:');
 
         $config = $this->getObjectAttribute($factory, 'config');
 
@@ -81,7 +81,7 @@ public function testShouldParseConfigurationAsExpected($config, $expectedConfig)
     public static function provideConfigs()
     {
         yield [
-            'rdkafka://theHost:1234?global%5Bgroup.id%5D=group-id',
+            'kafka://theHost:1234?global%5Bgroup.id%5D=group-id',
             [
                 'global' => [
                     'metadata.broker.list' => 'theHost:1234',