Skip to content

Commit aa2df46

Browse files
committed
Make PulsarTopicBuilder bean prototype scope
The builder is stateful and as such each injection point needs its own bean instance.
1 parent 3277577 commit aa2df46

File tree

1 file changed

+3
-1
lines changed
  • spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/pulsar

1 file changed

+3
-1
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535
import org.springframework.boot.util.LambdaSafe;
3636
import org.springframework.context.annotation.Bean;
3737
import org.springframework.context.annotation.Configuration;
38+
import org.springframework.context.annotation.Scope;
3839
import org.springframework.pulsar.core.DefaultPulsarClientFactory;
3940
import org.springframework.pulsar.core.DefaultSchemaResolver;
4041
import org.springframework.pulsar.core.DefaultTopicResolver;
@@ -179,7 +180,8 @@ PulsarFunctionAdministration pulsarFunctionAdministration(PulsarAdministration p
179180
}
180181

181182
@Bean
182-
@ConditionalOnMissingBean(PulsarTopicBuilder.class)
183+
@Scope("prototype")
184+
@ConditionalOnMissingBean
183185
PulsarTopicBuilder pulsarTopicBuilder() {
184186
return new PulsarTopicBuilder(TopicDomain.persistent, this.properties.getDefaults().getTenant(),
185187
this.properties.getDefaults().getNamespace());

0 commit comments

Comments
 (0)