diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaProperties.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaProperties.java index e0cd916be8c..8f8e16a4b6f 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaProperties.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaProperties.java @@ -917,7 +917,7 @@ public class KafkaProperties { * Whether to suppress the entire record from being written to the log when * retries are being attempted. */ - private boolean onlyLogRecordMetadata; + private boolean onlyLogRecordMetadata = true; /** * Whether the container should fail to start if at least one of the configured diff --git a/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java b/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java index c00a815286c..7872ac5c385 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java @@ -700,7 +700,7 @@ class KafkaAutoConfigurationTests { @Bean AfterRollbackProcessor afterRollbackProcessor() { - return (records, consumer, ex, recoverable) -> { + return (records, consumer, ex, recoverable, eosMode) -> { // no-op }; } diff --git a/spring-boot-project/spring-boot-dependencies/build.gradle b/spring-boot-project/spring-boot-dependencies/build.gradle index 0e1853e3661..b8bbcecdca1 100644 --- a/spring-boot-project/spring-boot-dependencies/build.gradle +++ b/spring-boot-project/spring-boot-dependencies/build.gradle @@ -1578,7 +1578,7 @@ bom { ] } } - library("Spring Kafka", "2.6.4") { + library("Spring Kafka", "2.7.0-M1") { group("org.springframework.kafka") { modules = [ "spring-kafka",