Merge pull request #562 from adumas37/fixing-kafka-default-configuration

Fixing kafka default configuration

Author: makasim

pkg/rdkafka/RdKafkaConnectionFactory.php

@@ -44,7 +44,7 @@ public function __construct($config = 'kafka:')
             throw new \LogicException('The config must be either an array of options, a DSN string or null');
         }
 
-        $this->config = array_replace($this->defaultConfig(), $config);
+        $this->config = array_replace_recursive($this->defaultConfig(), $config);
     }
 
     /**

pkg/rdkafka/Tests/RdKafkaConnectionFactoryTest.php

@@ -107,5 +107,19 @@ public static function provideConfigs()
                 ],
             ],
         ];
+
+        yield [
+            [
+                'global' => [
+                    'group.id' => 'group-id',
+                ],
+            ],
+            [
+                'global' => [
+                    'metadata.broker.list' => 'localhost:9092',
+                    'group.id' => 'group-id',
+                ],
+            ],
+        ];
     }
 }