diff --git a/commons/common-util/src/main/java/com/schbrain/common/util/BeanCopyUtils.java b/commons/common-util/src/main/java/com/schbrain/common/util/BeanCopyUtils.java
index 404edb64f00ba70e1dccd9e8d66dba71ef1e14d4..5d291af7acbc73b84e590436c2fecc6a123a3be7 100644
--- a/commons/common-util/src/main/java/com/schbrain/common/util/BeanCopyUtils.java
+++ b/commons/common-util/src/main/java/com/schbrain/common/util/BeanCopyUtils.java
@@ -17,7 +17,9 @@ import java.util.List;
 
 /**
  * 注意！！！此类是基于 cglib 实现的
+ * <p>
  * 默认的 cglib 只支持同名,同类型的属性转换,本类对此场景进行了增强,具体逻辑见 {@link DefaultConverter}
+ * <p>
  * 另外最重要的, cglib 是浅拷贝,意味着如果是引用类型,修改源对象会导致目标对象的值也被修改,使用时请注意！！！
  *
  * @author liaozan
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 7fe4e82aeeff7b4abdcf2801e8cfb67858abd4b7..f6a2a1d406f2447b347f94c7dfc3d59361f3e1d6 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,7 +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;
+import org.springframework.kafka.support.ProducerListener;
 
 /**
  * @author liaozan
@@ -22,9 +22,9 @@ public class KafkaAutoConfiguration {
     }
 
     @Bean
-    @ConditionalOnMissingBean
-    public KafkaMessageProducer defaultKafkaMessageProducer(KafkaTemplate<String, String> kafkaTemplate) {
-        return new KafkaMessageProducer(kafkaTemplate);
+    @ConditionalOnMissingBean(ProducerListener.class)
+    public KafkaLoggingProducerListener kafkaLoggingProducerListener() {
+        return new KafkaLoggingProducerListener();
     }
 
 }
diff --git a/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaLoggingProducerListener.java b/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaLoggingProducerListener.java
new file mode 100644
index 0000000000000000000000000000000000000000..37b0e513f97ad297e305efd1be9a18d61be3c2b1
--- /dev/null
+++ b/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaLoggingProducerListener.java
@@ -0,0 +1,30 @@
+package com.schbrain.framework.autoconfigure.kafka;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.kafka.clients.producer.ProducerRecord;
+import org.apache.kafka.clients.producer.RecordMetadata;
+import org.springframework.kafka.support.LoggingProducerListener;
+
+/**
+ * @author liaozan
+ * @since 2023/7/26
+ */
+@Slf4j
+public class KafkaLoggingProducerListener extends LoggingProducerListener<Object, Object> {
+
+    public KafkaLoggingProducerListener() {
+        this.setIncludeContents(false);
+    }
+
+    @Override
+    public void onSuccess(ProducerRecord<Object, Object> record, RecordMetadata metadata) {
+        log.debug("[{}] 消息发送成功, content: {}", record.topic(), record.value());
+    }
+
+    @Override
+    public void onError(ProducerRecord<Object, Object> record, RecordMetadata metadata, Exception exception) {
+        log.warn("[{}] 消息发送失败, content: {}", record.topic(), record.value());
+        super.onError(record, metadata, exception);
+    }
+
+}
diff --git a/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaMessageProducer.java b/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaMessageProducer.java
deleted file mode 100644
index 536669b96f9e2430ca5bbb918c3207cab57106cf..0000000000000000000000000000000000000000
--- a/starters/kafka-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/kafka/KafkaMessageProducer.java
+++ /dev/null
@@ -1,56 +0,0 @@
-package com.schbrain.framework.autoconfigure.kafka;
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.kafka.core.KafkaTemplate;
-import org.springframework.kafka.support.SendResult;
-import org.springframework.util.concurrent.ListenableFutureCallback;
-
-/**
- * @author liaozan
- * @since 2023/7/17
- */
-@Slf4j
-public class KafkaMessageProducer {
-
-    private final KafkaTemplate<String, String> kafkaTemplate;
-
-    public KafkaMessageProducer(KafkaTemplate<String, String> kafkaTemplate) {
-        this.kafkaTemplate = kafkaTemplate;
-    }
-
-    /**
-     * producer 异步方式发送数据
-     *
-     * @param topic topic名称
-     * @param message producer发送的数据
-     * @param description 消息描述
-     */
-    public void sendMessageAsync(String topic, String message, String description) {
-        sendMessageAsync(topic, message, new ListenableFutureCallback<>() {
-            @Override
-            public void onSuccess(SendResult<String, String> sendResult) {
-                log.debug("{} 消息发送成功, message: {}", description, message);
-            }
-
-            @Override
-            public void onFailure(Throwable exception) {
-                log.error("{} 消息发送失败, {}", description, exception.getMessage(), exception);
-            }
-        });
-    }
-
-    /**
-     * producer 异步方式发送数据
-     *
-     * @param topic topic名称
-     * @param message producer发送的数据
-     */
-    public void sendMessageAsync(String topic, String message, ListenableFutureCallback<SendResult<String, String>> callback) {
-        try {
-            kafkaTemplate.send(topic, message).addCallback(callback);
-        } catch (Exception exception) {
-            log.error("消息发送失败, {}", exception.getMessage(), exception);
-        }
-    }
-
-}