Skip to content

Commit c125e0e

Browse files
committed
Upgrade to Spring Kafka 2.7.0-M1
Closes gh-24592
1 parent dff6430 commit c125e0e

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaProperties.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -917,7 +917,7 @@ public enum Type {
917917
* Whether to suppress the entire record from being written to the log when
918918
* retries are being attempted.
919919
*/
920-
private boolean onlyLogRecordMetadata;
920+
private boolean onlyLogRecordMetadata = true;
921921

922922
/**
923923
* Whether the container should fail to start if at least one of the configured

spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -700,7 +700,7 @@ static class AfterRollbackProcessorConfiguration {
700700

701701
@Bean
702702
AfterRollbackProcessor<Object, Object> afterRollbackProcessor() {
703-
return (records, consumer, ex, recoverable) -> {
703+
return (records, consumer, ex, recoverable, eosMode) -> {
704704
// no-op
705705
};
706706
}

spring-boot-project/spring-boot-dependencies/build.gradle

+1-1
Original file line numberDiff line numberDiff line change
@@ -1578,7 +1578,7 @@ bom {
15781578
]
15791579
}
15801580
}
1581-
library("Spring Kafka", "2.6.4") {
1581+
library("Spring Kafka", "2.7.0-M1") {
15821582
group("org.springframework.kafka") {
15831583
modules = [
15841584
"spring-kafka",

0 commit comments

Comments
 (0)