diff --git a/pom.xml b/pom.xml index feb15ae7f1ce4fefad906e588b353b14dd949aa4..bdba8f91d56768cc12e1e2f8bb97f73a98c98cba 100644 --- a/pom.xml +++ b/pom.xml @@ -740,6 +740,12 @@ + + schbrain + + true + + dev 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 37b0e513f97ad297e305efd1be9a18d61be3c2b1..e67bb6c0a6950c6d635d8d898760a9c6db9f0c78 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 { - public KafkaLoggingProducerListener() { - this.setIncludeContents(false); - } - @Override public void onSuccess(ProducerRecord record, RecordMetadata metadata) { - log.debug("[{}] 消息发送成功, content: {}", record.topic(), record.value()); + log.info("[{}] 消息发送成功, content: {}", record.topic(), record.value()); } @Override public void onError(ProducerRecord record, RecordMetadata metadata, Exception exception) { log.warn("[{}] 消息发送失败, content: {}", record.topic(), record.value()); - super.onError(record, metadata, exception); } }