From 560556cfe9ecdcde4dd81c8eb7e1535f33021470 Mon Sep 17 00:00:00 2001 From: ewezy Date: Tue, 6 Aug 2024 14:17:06 +0800 Subject: [PATCH] Update kafka config brokers --- 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 28c0ee1..6f68fc5 100644 --- a/treatment-service/integration-test/fetch_treatment_it_test.go +++ b/treatment-service/integration-test/fetch_treatment_it_test.go @@ -400,7 +400,7 @@ func (suite *TreatmentServiceTestSuite) SetupSuite() { } fmt.Println(kafkaPort) - os.Setenv("ASSIGNEDTREATMENTLOGGER_KAFKACONFIG_BROKERS", fmt.Sprintf("%s:%s", kafkaHost, kafkaPort.Port())) + os.Setenv("ASSIGNEDTREATMENTLOGGER_KAFKACONFIG_BROKERS", fmt.Sprintf("0.0.0.0:%s", kafkaPort.Port())) } suite.kafka = kafka