fix(tests): enable to get broker connection from env

leroy-merlin-br · Oct 10, 2023 · a3551b5 · a3551b5
1 parent f44e2f9
commit a3551b5
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/tests/Unit/Connectors/Producer/ConnectorTest.php b/tests/Unit/Connectors/Producer/ConnectorTest.php
@@ -29,7 +29,8 @@ public function testItShouldMakeSetup(): void
             m::mock(KafkaProducer::class)
         );
 
-        $broker = new Broker('kafka:9092', new None());
+        $connections = env('KAFKA_BROKER_CONNECTIONS', 'kafka:9092');
+        $broker = new Broker($connections, new None());
         $producerConfigOptions = m::mock(ProducerConfigOptions::class);
 
         $connector = new Connector();
@@ -79,7 +80,8 @@ public function testItShouldMakeSetupWithoutHandleResponse(): void
             m::mock(KafkaProducer::class)
         );
 
-        $broker = new Broker('kafka:9092', new None());
+        $connections = env('KAFKA_BROKER_CONNECTIONS', 'kafka:9092');
+        $broker = new Broker($connections, new None());
         $producerConfigOptions = m::mock(ProducerConfigOptions::class);
 
         $connector = new Connector();