commit 07fcb37a4c7b10472a87d4af43b03eeef8ca8785
author Xu Qiaolun <Jamesxql@Gmail.com> Fri Jun 13 14:34:10 2025 +0800
committer GitHub <noreply@github.com> Fri Jun 13 14:34:10 2025 +0800
tree d7564d8e847f41fc6bc8fcd3becaac2cb3074490
parent fb044e2e4746360ae6bbe4dc89ab2c263eb76d81

[ISSUE #718]fix: registers a null consumerBuilder for RocketMQClientTemplate

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java

diff --git a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java
index 35837c6..8f65b40 100644
--- a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java
+++ b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java
@@ -96,8 +96,9 @@
 
         try {
             final ClientServiceProvider provider = ClientServiceProvider.loadService();
-            SimpleConsumerBuilder simpleConsumerBuilder = provider.newSimpleConsumerBuilder();
-            simpleConsumerInfo = createConsumer(annotation, simpleConsumerBuilder);
+            consumerBuilder = provider.newSimpleConsumerBuilder();
+            simpleConsumerInfo = createConsumer(annotation, consumerBuilder);
+            simpleConsumer = consumerBuilder.build();
         } catch (Exception e) {
             log.error("Failed to startup SimpleConsumer for RocketMQTemplate {}", beanName, e);
         }