From aa0f10568b7074a33aaa0bb70559e529d971b942 Mon Sep 17 00:00:00 2001 From: ewezy Date: Mon, 5 Aug 2024 17:44:54 +0800 Subject: [PATCH] Update kafka broker --- treatment-service/integration-test/fetch_treatment_it_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/treatment-service/integration-test/fetch_treatment_it_test.go b/treatment-service/integration-test/fetch_treatment_it_test.go index 76f8b2d..263d13c 100644 --- 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 {