Add nullability annotations to module/spring-boot-pulsar

See gh-46587

Author: mhalbritter

module/spring-boot-pulsar/src/main/java/org/springframework/boot/pulsar/autoconfigure/PulsarConfiguration.java

@@ -25,6 +25,7 @@
 import org.apache.pulsar.client.api.Schema;
 import org.apache.pulsar.common.naming.TopicDomain;
 import org.apache.pulsar.common.schema.SchemaType;
+import org.jspecify.annotations.Nullable;
 
 import org.springframework.beans.factory.ObjectProvider;
 import org.springframework.beans.factory.config.ConfigurableBeanFactory;
@@ -127,7 +128,8 @@ DefaultSchemaResolver pulsarSchemaResolver(ObjectProvider<SchemaResolverCustomiz
 		return schemaResolver;
 	}
 
-	private void addCustomSchemaMappings(DefaultSchemaResolver schemaResolver, List<TypeMapping> typeMappings) {
+	private void addCustomSchemaMappings(DefaultSchemaResolver schemaResolver,
+			@Nullable List<TypeMapping> typeMappings) {
 		if (typeMappings != null) {
 			typeMappings.forEach((typeMapping) -> addCustomSchemaMapping(schemaResolver, typeMapping));
 		}
@@ -139,11 +141,17 @@ private void addCustomSchemaMapping(DefaultSchemaResolver schemaResolver, TypeMa
 			Class<?> messageType = typeMapping.messageType();
 			SchemaType schemaType = schemaInfo.schemaType();
 			Class<?> messageKeyType = schemaInfo.messageKeyType();
-			Schema<?> schema = schemaResolver.resolveSchema(schemaType, messageType, messageKeyType).orElseThrow();
+			Schema<?> schema = getSchema(schemaResolver, schemaType, messageType, messageKeyType);
 			schemaResolver.addCustomSchemaMapping(typeMapping.messageType(), schema);
 		}
 	}
 
+	@SuppressWarnings("NullAway") // Resolved.orElseThrow() doesn't return nullable
+	private Schema<Object> getSchema(DefaultSchemaResolver schemaResolver, SchemaType schemaType, Class<?> messageType,
+			@Nullable Class<?> messageKeyType) {
+		return schemaResolver.resolveSchema(schemaType, messageType, messageKeyType).orElseThrow();
+	}
+
 	@SuppressWarnings("unchecked")
 	private void applySchemaResolverCustomizers(List<SchemaResolverCustomizer<?>> customizers,
 			DefaultSchemaResolver schemaResolver) {

module/spring-boot-pulsar/src/main/java/org/springframework/boot/pulsar/autoconfigure/PulsarContainerFactoryCustomizers.java

@@ -20,6 +20,8 @@
 import java.util.Collections;
 import java.util.List;
 
+import org.jspecify.annotations.Nullable;
+
 import org.springframework.boot.util.LambdaSafe;
 import org.springframework.pulsar.config.PulsarContainerFactory;
 import org.springframework.pulsar.core.PulsarConsumerFactory;
@@ -34,7 +36,7 @@ class PulsarContainerFactoryCustomizers {
 
 	private final List<PulsarContainerFactoryCustomizer<?>> customizers;
 
-	PulsarContainerFactoryCustomizers(List<? extends PulsarContainerFactoryCustomizer<?>> customizers) {
+	PulsarContainerFactoryCustomizers(@Nullable List<? extends PulsarContainerFactoryCustomizer<?>> customizers) {
 		this.customizers = (customizers != null) ? new ArrayList<>(customizers) : Collections.emptyList();
 	}