diff --git a/tests/Unit/Connectors/Producer/ConnectorTest.php b/tests/Unit/Connectors/Producer/ConnectorTest.php index 650dbd02..dc2dfe96 100644 --- 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();