Add Spring for Apache Pulsar

- remove custom docker image reference

Author: onobc

spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/pulsar/PulsarAutoConfigurationIntegrationTests.java

@@ -62,7 +62,7 @@ class PulsarAutoConfigurationIntegrationTests {
 
 	@DynamicPropertySource
 	static void pulsarProperties(DynamicPropertyRegistry registry) {
-		registry.add("spring.pulsar.client.service-url", PULSAR_CONTAINER::getPulsarBrokerUrl);
+ 		registry.add("spring.pulsar.client.service-url", PULSAR_CONTAINER::getPulsarBrokerUrl);
 		registry.add("spring.pulsar.administration.service-url", PULSAR_CONTAINER::getHttpServiceUrl);
 	}
 

spring-boot-project/spring-boot-tools/spring-boot-test-support/src/main/java/org/springframework/boot/testsupport/testcontainers/DockerImageNames.java

@@ -16,8 +16,6 @@
 
 package org.springframework.boot.testsupport.testcontainers;
 
-import java.util.Locale;
-
 import org.testcontainers.utility.DockerImageName;
 
 /**
@@ -42,6 +40,8 @@ public final class DockerImageNames {
 
 	private static final String NEO4J_VERSION = "4.4.11";
 
+	private static final String PULSAR_VERSION = "2.11.0";
+
 	private static final String POSTGRESQL_VERSION = "14.0";
 
 	private static final String RABBIT_VERSION = "3.11-alpine";
@@ -114,7 +114,7 @@ public static DockerImageName neo4j() {
 	 * @return a docker image name for running pulsar
 	 */
 	public static DockerImageName pulsar() {
-		return isRunningOnMacM1() ? getMacM1PulsarImage() : getStandardPulsarImage();
+		return DockerImageName.parse("apachepulsar/pulsar").withTag(PULSAR_VERSION);
 	}
 
 	/**
@@ -150,18 +150,4 @@ public static DockerImageName registry() {
 		return DockerImageName.parse("registry").withTag(REGISTRY_VERSION);
 	}
 
-	private static boolean isRunningOnMacM1() {
-		String osName = System.getProperty("os.name").toLowerCase(Locale.ENGLISH);
-		String osArchitecture = System.getProperty("os.arch").toLowerCase(Locale.ENGLISH);
-		return osName.contains("mac") && osArchitecture.equals("aarch64");
-	}
-
-	private static DockerImageName getStandardPulsarImage() {
-		return DockerImageName.parse("apachepulsar/pulsar:2.11.0");
-	}
-
-	private static DockerImageName getMacM1PulsarImage() {
-		return DockerImageName.parse("kezhenxu94/pulsar").asCompatibleSubstituteFor("apachepulsar/pulsar");
-	}
-
 }