Ping actual localhost ip

caraml-dev · Aug 7, 2024 · 5e0ba9e · 5e0ba9e
1 parent abba2eb
commit 5e0ba9e
Showing 1 changed file with 13 additions 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
@@ -370,7 +370,19 @@ func (suite *TreatmentServiceTestSuite) SetupSuite() {
 		panic(err)
 	}
 	fmt.Println(brokers)
-	pinger, err := probing.NewPinger(brokers[0])
+
+	networks, err := kafkaContainer.Networks(ctx)
+	if err != nil {
+		panic(err)
+	}
+	fmt.Println(networks)
+
+	port, err := kafkaContainer.MappedPort(ctx, "9093/tcp")
+	if err != nil {
+		panic(err)
+	}
+
+	pinger, err := probing.NewPinger(fmt.Sprintf("127.0.0.1:%s", port))
 	if err != nil {
 		panic(err)
 	}