Pass global hub node ip as kafka advertisedhost

Signed-off-by: clyang82 <[email protected]>
stolostron · Dec 3, 2024 · 0a733c8 · 0a733c8
1 parent 5c541d9
commit 0a733c8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/test/e2e/suite_test.go b/test/e2e/suite_test.go
@@ -305,6 +305,7 @@ func deployGlobalHub() {
 				"global-hub.open-cluster-management.io/catalog-source-name":      "operatorhubio-catalog",
 				"global-hub.open-cluster-management.io/catalog-source-namespace": "olm",
 				"global-hub.open-cluster-management.io/kafka-use-nodeport":       "",
+				"global-hub.open-cluster-management.io/kind-cluster-ip":          os.Getenv("GLOBAL_HUB_NODE_IP"),
 			},
 		},
 		Spec: v1alpha4.MulticlusterGlobalHubSpec{

diff --git a/test/script/e2e_run.sh b/test/script/e2e_run.sh
@@ -96,6 +96,9 @@ verbose=${verbose:=5}
 # Go programs typically use dynamic linking for C libraries: confluent-kafka package is used in e2e test
 export CGO_ENABLED=1
 
+# need set it as kafka advertiesehost to pass tls authn
+export GLOBAL_HUB_NODE_IP=${global_hub_node_ip}
+
 if [ "${filter}" = "e2e-test-prune" ]; then
   export ISPRUNE="true"
   echo "run prune"