Fix format

Author: onobc

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/pulsar/PulsarProperties.java

@@ -854,6 +854,7 @@ public void setObservationEnabled(boolean observationEnabled) {
 		public Startup getStartup() {
 			return this.startup;
 		}
+
 	}
 
 	public static class Reader {
@@ -932,6 +933,7 @@ public void setReadCompacted(boolean readCompacted) {
 		public Startup getStartup() {
 			return this.startup;
 		}
+
 	}
 
 	public static class Startup {
@@ -961,6 +963,7 @@ public FailurePolicy getOnFailure() {
 		public void setOnFailure(FailurePolicy onFailure) {
 			this.onFailure = onFailure;
 		}
+
 	}
 
 	public enum FailurePolicy {
@@ -973,6 +976,7 @@ public enum FailurePolicy {
 
 		/** Retry startup asynchronously. */
 		RETRY;
+
 	}
 
 	public static class Template {

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/pulsar/PulsarPropertiesMapper.java

@@ -208,9 +208,9 @@ private void customizeListenerStartupProperties(PulsarContainerProperties contai
 		PropertyMapper map = PropertyMapper.get().alwaysApplyingWhenNonNull();
 		map.from(properties::getTimeout).to(containerProperties::setConsumerStartTimeout);
 		map.from(properties::getOnFailure)
-				.as(FailurePolicy::name)
-				.as(StartupFailurePolicy::valueOf)
-				.to(containerProperties::setStartupFailurePolicy);
+			.as(FailurePolicy::name)
+			.as(StartupFailurePolicy::valueOf)
+			.to(containerProperties::setStartupFailurePolicy);
 	}
 
 	<T> void customizeReaderBuilder(ReaderBuilder<T> readerBuilder) {
@@ -235,9 +235,9 @@ private void customizeReaderStartupProperties(PulsarReaderContainerProperties re
 		PropertyMapper map = PropertyMapper.get().alwaysApplyingWhenNonNull();
 		map.from(properties::getTimeout).to(readerContainerProperties::setReaderStartTimeout);
 		map.from(properties::getOnFailure)
-				.as(FailurePolicy::name)
-				.as(StartupFailurePolicy::valueOf)
-				.to(readerContainerProperties::setStartupFailurePolicy);
+			.as(FailurePolicy::name)
+			.as(StartupFailurePolicy::valueOf)
+			.to(readerContainerProperties::setStartupFailurePolicy);
 	}
 
 	private Consumer<Duration> timeoutProperty(BiConsumer<Integer, TimeUnit> setter) {

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/pulsar/PulsarReactivePropertiesMapper.java

@@ -106,9 +106,9 @@ private void customizeListenerStartupProperties(ReactivePulsarContainerPropertie
 		PulsarProperties.Startup properties = this.properties.getListener().getStartup();
 		PropertyMapper map = PropertyMapper.get().alwaysApplyingWhenNonNull();
 		map.from(properties::getOnFailure)
-				.as(FailurePolicy::name)
-				.as(StartupFailurePolicy::valueOf)
-				.to(containerProperties::setStartupFailurePolicy);
+			.as(FailurePolicy::name)
+			.as(StartupFailurePolicy::valueOf)
+			.to(containerProperties::setStartupFailurePolicy);
 	}
 
 	void customizeMessageReaderBuilder(ReactiveMessageReaderBuilder<?> builder) {

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

@@ -316,4 +316,5 @@ void customizeReaderContainerProperties() {
 		assertThat(readerContainerProperties.getStartupFailurePolicy()).isEqualTo(StartupFailurePolicy.CONTINUE);
 		assertThat(readerContainerProperties.getReaderStartTimeout()).isEqualTo(Duration.ofSeconds(25));
 	}
+
 }