Update pom.xml

pom.xml

@@ -740,6 +740,12 @@
     </pluginRepositories>
 
     <profiles>
+        <profile>
+            <id>schbrain</id>
+            <activation>
+                <activeByDefault>true</activeByDefault>
+            </activation>
+        </profile>
         <!-- 开发环境 -->
         <profile>
             <id>dev</id>

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);
     }
 
 }