Update kafka broker

caraml-dev · Aug 5, 2024 · aa0f105 · aa0f105
1 parent 302b2f3
commit aa0f105
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/treatment-service/integration-test/fetch_treatment_it_test.go b/treatment-service/integration-test/fetch_treatment_it_test.go
@@ -380,7 +380,7 @@ func (suite *TreatmentServiceTestSuite) SetupSuite() {
 		panic(err)
 	}
 	suite.kafka = kafka
-	os.Setenv("ASSIGNEDTREATMENTLOGGER_KAFKACONFIG_BROKERS", "localhost:9092")
+	os.Setenv("ASSIGNEDTREATMENTLOGGER_KAFKACONFIG_BROKERS", "broker:9092")
 
 	c, treatmentServer := setupTreatmentService(suite.managementServiceServer.URL)
 	waitForServerToListen := func() bool {