Browse Source

Upgrade to Spring Kafka 2.7.0-M1

Closes gh-24592
pull/24964/head
Andy Wilkinson 5 years ago
parent
commit
c125e0ee35
  1. 2
      spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaProperties.java
  2. 2
      spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationTests.java
  3. 2
      spring-boot-project/spring-boot-dependencies/build.gradle

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

@ -917,7 +917,7 @@ public class KafkaProperties { @@ -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

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

@ -700,7 +700,7 @@ class KafkaAutoConfigurationTests { @@ -700,7 +700,7 @@ class KafkaAutoConfigurationTests {
@Bean
AfterRollbackProcessor<Object, Object> afterRollbackProcessor() {
return (records, consumer, ex, recoverable) -> {
return (records, consumer, ex, recoverable, eosMode) -> {
// no-op
};
}

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

@ -1578,7 +1578,7 @@ bom { @@ -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",

Loading…
Cancel
Save