From 6d61e3a9fbcc8e99ab68f7ef41cfc67c78160dff Mon Sep 17 00:00:00 2001
From: liaozan <378024053@qq.com>
Date: Mon, 24 Jul 2023 18:29:08 +0800
Subject: [PATCH] no messages

---
 .../autoconfigure/kafka/KafkaAutoConfiguration.java    |  5 +++--
 ...{MessageProducer.java => KafkaMessageProducer.java} | 10 ++++++----
 2 files changed, 9 insertions(+), 6 deletions(-)
 rename starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/{MessageProducer.java => KafkaMessageProducer.java} (87%)

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 78d3fd9..7fe4e82 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 b9b9fdb..536669b 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 异步方式发送数据
-- 
GitLab