diff --git a/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaAutoConfiguration.java b/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaAutoConfiguration.java
index 78d3fd92ff2940112119549f47447ddbb9096416..7fe4e82aeeff7b4abdcf2801e8cfb67858abd4b7 100644
--- a/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaAutoConfiguration.java
+++ b/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaAutoConfiguration.java
@@ -6,6 +6,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.kafka.config.KafkaListenerConfigUtils;
+import org.springframework.kafka.core.KafkaTemplate;
 
 /**
  * @author liaozan
@@ -22,8 +23,8 @@ public class KafkaAutoConfiguration {
 
     @Bean
     @ConditionalOnMissingBean
-    public MessageProducer defaultMessageProducer() {
-        return new MessageProducer();
+    public KafkaMessageProducer defaultKafkaMessageProducer(KafkaTemplate<String, String> kafkaTemplate) {
+        return new KafkaMessageProducer(kafkaTemplate);
     }
 
 }
diff --git a/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/MessageProducer.java b/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaMessageProducer.java
similarity index 87%
rename from starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/MessageProducer.java
rename to starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaMessageProducer.java
index b9b9fdb657251e6fb7d8303ca6c939993cf03411..536669b96f9e2430ca5bbb918c3207cab57106cf 100644
--- a/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/MessageProducer.java
+++ b/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaMessageProducer.java
@@ -1,7 +1,6 @@
 package com.schbrain.framework.autoconfigure.kafka;
 
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.support.SendResult;
 import org.springframework.util.concurrent.ListenableFutureCallback;
@@ -11,10 +10,13 @@ import org.springframework.util.concurrent.ListenableFutureCallback;
  * @since 2023/7/17
  */
 @Slf4j
-public class MessageProducer {
+public class KafkaMessageProducer {
 
-    @Autowired
-    private KafkaTemplate<String, String> kafkaTemplate;
+    private final KafkaTemplate<String, String> kafkaTemplate;
+
+    public KafkaMessageProducer(KafkaTemplate<String, String> kafkaTemplate) {
+        this.kafkaTemplate = kafkaTemplate;
+    }
 
     /**
      * producer 异步方式发送数据