diff --git a/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/test/java/org/springframework/cloud/stream/binder/pulsar/PulsarExtendedBindingPropertiesTests.java b/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/test/java/org/springframework/cloud/stream/binder/pulsar/PulsarExtendedBindingPropertiesTests.java index f9fa9def1..9df2491aa 100644 --- a/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/test/java/org/springframework/cloud/stream/binder/pulsar/PulsarExtendedBindingPropertiesTests.java +++ b/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/test/java/org/springframework/cloud/stream/binder/pulsar/PulsarExtendedBindingPropertiesTests.java @@ -97,7 +97,7 @@ class PulsarExtendedBindingPropertiesTests { PulsarContainerProperties pulsarContainerProperties = new PulsarContainerProperties(); pulsarContainerProperties.getPulsarConsumerProperties().putAll(consumerProps); assertThat(pulsarContainerProperties.getSubscriptionName()).isNull(); - assertThat(pulsarContainerProperties.getSubscriptionType()).isEqualTo(SubscriptionType.Exclusive); + assertThat(pulsarContainerProperties.getSubscriptionType()).isNull(); pulsarContainerProperties.updateContainerProperties(); assertThat(pulsarContainerProperties.getSubscriptionName()).isEqualTo("my-foo-sbscription"); assertThat(pulsarContainerProperties.getSubscriptionType()).isEqualTo(SubscriptionType.Shared);