diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java index 066ccbe7..f91c94f9 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java @@ -119,7 +119,6 @@ public class CachingPulsarProducerFactory extends DefaultPulsarProducerFactor @SuppressWarnings("unchecked") private Producer wrapProducerWithCloseCallback(Producer producer, Consumer> closeCallback) { ProxyFactory factory = new ProxyFactory(producer); - factory.setProxyTargetClass(true); factory.addAdvice(new MethodInterceptor() { @Nullable @Override