add loading

wind57 · wind57 · commit fc5b59ddd961 · 2026-05-04T16:41:53.000+03:00
Signed-off-by: wind57 &lt;eugen.rabii@gmail.com&gt;
diff --git a/spring-cloud-kubernetes-test-support/src/main/java/org/springframework/cloud/kubernetes/integration/tests/commons/k3s/NativeClientIntegrationTestExtension.java b/spring-cloud-kubernetes-test-support/src/main/java/org/springframework/cloud/kubernetes/integration/tests/commons/k3s/NativeClientIntegrationTestExtension.java
@@ -110,11 +110,13 @@ public void beforeAll(ExtensionContext context) throws Exception {
 
 		// 10. deploy kafka
 		if (scenario.deployKafka()) {
+			Images.loadKafka(container);
 			nativeClientKubernetesFixture.kafka(Phase.CREATE);
 		}
 
 		// 11. deploy rabbitMq
 		if (scenario.deployRabbitMq()) {
+			Images.loadRabbitmq(container);
 			nativeClientKubernetesFixture.rabbitMq(Phase.CREATE);
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -110,11 +110,13 @@ public void beforeAll(ExtensionContext context) throws Exception {`
`110`	`110`
`111`	`111`	`// 10. deploy kafka`
`112`	`112`	`if (scenario.deployKafka()) {`
	`113`	`+ Images.loadKafka(container);`
`113`	`114`	`nativeClientKubernetesFixture.kafka(Phase.CREATE);`
`114`	`115`	`}`
`115`	`116`
`116`	`117`	`// 11. deploy rabbitMq`
`117`	`118`	`if (scenario.deployRabbitMq()) {`
	`119`	`+ Images.loadRabbitmq(container);`
`118`	`120`	`nativeClientKubernetesFixture.rabbitMq(Phase.CREATE);`
`119`	`121`	`}`
`120`	`122`	`}`