diff --git a/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarProperties.java b/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarProperties.java index dd899f29..8f5adc32 100644 --- a/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarProperties.java +++ b/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarProperties.java @@ -527,11 +527,6 @@ public class PulsarProperties { */ private CompressionType compressionType; - /** - * Name of the initial subscription of the topic. - */ - private String initialSubscriptionName; - /** * Type of access to the topic the producer requires. */ @@ -651,14 +646,6 @@ public class PulsarProperties { this.compressionType = compressionType; } - public String getInitialSubscriptionName() { - return this.initialSubscriptionName; - } - - public void setInitialSubscriptionName(String initialSubscriptionName) { - this.initialSubscriptionName = initialSubscriptionName; - } - public ProducerAccessMode getProducerAccessMode() { return this.producerAccessMode; } @@ -692,7 +679,6 @@ public class PulsarProperties { map.from(this::isBatchingEnabled).to(properties.in("batchingEnabled")); map.from(this::isChunkingEnabled).to(properties.in("chunkingEnabled")); map.from(this::getCompressionType).to(properties.in("compressionType")); - map.from(this::getInitialSubscriptionName).to(properties.in("initialSubscriptionName")); map.from(this::getProducerAccessMode).to(properties.in("accessMode")); return properties; diff --git a/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarReactiveProperties.java b/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarReactiveProperties.java index 0cbccfcc..549c7825 100644 --- a/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarReactiveProperties.java +++ b/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarReactiveProperties.java @@ -166,11 +166,6 @@ public class PulsarReactiveProperties { */ private CompressionType compressionType; - /** - * Name of the initial subscription of the topic. - */ - private String initialSubscriptionName; - /** * Type of access to the topic the producer requires. */ @@ -282,14 +277,6 @@ public class PulsarReactiveProperties { this.compressionType = compressionType; } - public String getInitialSubscriptionName() { - return this.initialSubscriptionName; - } - - public void setInitialSubscriptionName(String initialSubscriptionName) { - this.initialSubscriptionName = initialSubscriptionName; - } - public ProducerAccessMode getProducerAccessMode() { return this.producerAccessMode; } @@ -320,7 +307,6 @@ public class PulsarReactiveProperties { map.from(this::getBatchingEnabled).to(spec::setBatchingEnabled); map.from(this::getChunkingEnabled).to(spec::setChunkingEnabled); map.from(this::getCompressionType).to(spec::setCompressionType); - map.from(this::getInitialSubscriptionName).to(spec::setInitialSubscriptionName); map.from(this::getProducerAccessMode).to(spec::setAccessMode); return new ImmutableReactiveMessageSenderSpec(spec);