From b44d98e238f8fe90c312b627aaf425e936c56280 Mon Sep 17 00:00:00 2001
From: liaozan <378024053@qq.com>
Date: Mon, 11 Mar 2024 00:42:08 +0800
Subject: [PATCH] Update pom.xml

---
 pom.xml                                                    | 6 ++++++
 .../autoconfigure/kafka/KafkaLoggingProducerListener.java  | 7 +------
 2 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/pom.xml b/pom.xml
index feb15ae..bdba8f9 100644
--- a/pom.xml
+++ b/pom.xml
@@ -740,6 +740,12 @@
     </pluginRepositories>
 
     <profiles>
+        <profile>
+            <id>schbrain</id>
+            <activation>
+                <activeByDefault>true</activeByDefault>
+            </activation>
+        </profile>
         <!-- 开发环境 -->
         <profile>
             <id>dev</id>
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
index 37b0e51..e67bb6c 100644
--- 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
@@ -12,19 +12,14 @@ import org.springframework.kafka.support.LoggingProducerListener;
 @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());
+        log.info("[{}] 消息发送成功, 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);
     }
 
 }
-- 
GitLab