Test exposed kafka host and port

caraml-dev · Aug 6, 2024 · c2c9725 · c2c9725
1 parent a04432c
commit c2c9725
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/treatment-service/integration-test/docker-compose/kafka/docker-compose.yaml b/treatment-service/integration-test/docker-compose/kafka/docker-compose.yaml
@@ -9,7 +9,7 @@ services:
     environment:
       KAFKA_BROKER_ID: 1
       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: 'CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT'
-      KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT://broker:29092,PLAINTEXT_HOST://broker:9092'
+      KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT://broker:29092,PLAINTEXT_HOST://localhost:9092'
       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
       KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
       KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1

diff --git a/treatment-service/integration-test/fetch_treatment_it_test.go b/treatment-service/integration-test/fetch_treatment_it_test.go
@@ -387,9 +387,10 @@ func (suite *TreatmentServiceTestSuite) SetupSuite() {
 			panic(err)
 		}
 		fmt.Println(kafkaPort)
+
+		os.Setenv("ASSIGNEDTREATMENTLOGGER_KAFKACONFIG_BROKERS", fmt.Sprintf("%s:%s", kafkaHost, kafkaPort.Port()))
 	}
 	suite.kafka = kafka
-	os.Setenv("ASSIGNEDTREATMENTLOGGER_KAFKACONFIG_BROKERS", "localhost:9092")
 
 	c, treatmentServer := setupTreatmentService(suite.managementServiceServer.URL)
 	waitForServerToListen := func() bool {