From 9f4eeac34c14fe158cefe7260b914fca9ccd31ad Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Mon, 13 Feb 2023 14:43:31 -0500 Subject: [PATCH] Polish to the previous commit. Adding Nullable to the partitin count private method. --- .../stream/binder/provisioning/PulsarTopicProvisioner.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/spring-pulsar-spring-cloud-stream-binder/src/main/java/org/springframework/pulsar/spring/cloud/stream/binder/provisioning/PulsarTopicProvisioner.java b/spring-pulsar-spring-cloud-stream-binder/src/main/java/org/springframework/pulsar/spring/cloud/stream/binder/provisioning/PulsarTopicProvisioner.java index 27c624c3..b4fee3d7 100644 --- a/spring-pulsar-spring-cloud-stream-binder/src/main/java/org/springframework/pulsar/spring/cloud/stream/binder/provisioning/PulsarTopicProvisioner.java +++ b/spring-pulsar-spring-cloud-stream-binder/src/main/java/org/springframework/pulsar/spring/cloud/stream/binder/provisioning/PulsarTopicProvisioner.java @@ -22,6 +22,7 @@ import org.springframework.cloud.stream.provisioning.ConsumerDestination; import org.springframework.cloud.stream.provisioning.ProducerDestination; import org.springframework.cloud.stream.provisioning.ProvisioningException; import org.springframework.cloud.stream.provisioning.ProvisioningProvider; +import org.springframework.lang.Nullable; import org.springframework.pulsar.core.PulsarAdministration; import org.springframework.pulsar.core.PulsarTopic; import org.springframework.pulsar.spring.cloud.stream.binder.properties.PulsarBinderConfigurationProperties; @@ -57,7 +58,7 @@ public class PulsarTopicProvisioner implements return new PulsarDestination(pulsarTopic.topicName(), pulsarTopic.numberOfPartitions()); } - private int getPartitionCount(Integer partitionCountConfig) { + private int getPartitionCount(@Nullable Integer partitionCountConfig) { var partitionCount = this.pulsarBinderConfigurationProperties.getPartitionCount(); if (partitionCountConfig != null && partitionCountConfig > 0) { partitionCount = partitionCountConfig;