Remove deprecated Spring Kafka's only-log-record-metadata property

See gh-30089
pull/30220/head
Stephane Nicoll 3 years ago
parent 9bf77b1a06
commit 0e07eb2393

@ -178,7 +178,6 @@ public class ConcurrentKafkaListenerContainerFactoryConfigurer {
map.from(properties::getMonitorInterval).as(Duration::getSeconds).as(Number::intValue) map.from(properties::getMonitorInterval).as(Duration::getSeconds).as(Number::intValue)
.to(container::setMonitorInterval); .to(container::setMonitorInterval);
map.from(properties::getLogContainerConfig).to(container::setLogContainerConfig); map.from(properties::getLogContainerConfig).to(container::setLogContainerConfig);
map.from(properties::isOnlyLogRecordMetadata).to(container::setOnlyLogRecordMetadata);
map.from(properties::isMissingTopicsFatal).to(container::setMissingTopicsFatal); map.from(properties::isMissingTopicsFatal).to(container::setMissingTopicsFatal);
map.from(properties::isImmediateStop).to(container::setStopImmediate); map.from(properties::isImmediateStop).to(container::setStopImmediate);
map.from(this.transactionManager).to(container::setTransactionManager); map.from(this.transactionManager).to(container::setTransactionManager);

@ -934,12 +934,6 @@ public class KafkaProperties {
*/ */
private Boolean logContainerConfig; private Boolean logContainerConfig;
/**
* Whether to suppress the entire record from being written to the log when
* retries are being attempted.
*/
private boolean onlyLogRecordMetadata = true;
/** /**
* Whether the container should fail to start if at least one of the configured * Whether the container should fail to start if at least one of the configured
* topics are not present on the broker. * topics are not present on the broker.
@ -1056,14 +1050,6 @@ public class KafkaProperties {
this.logContainerConfig = logContainerConfig; this.logContainerConfig = logContainerConfig;
} }
public boolean isOnlyLogRecordMetadata() {
return this.onlyLogRecordMetadata;
}
public void setOnlyLogRecordMetadata(boolean onlyLogRecordMetadata) {
this.onlyLogRecordMetadata = onlyLogRecordMetadata;
}
public boolean isMissingTopicsFatal() { public boolean isMissingTopicsFatal() {
return this.missingTopicsFatal; return this.missingTopicsFatal;
} }

@ -1503,6 +1503,16 @@
"name": "spring.kafka.jaas.control-flag", "name": "spring.kafka.jaas.control-flag",
"defaultValue": "required" "defaultValue": "required"
}, },
{
"name": "spring.kafka.listener.only-log-record-metadata",
"type": "java.lang.Boolean",
"defaultValue": true,
"description": "Whether to suppress the entire record from being written to the log when retries are being attempted.",
"deprecation": {
"reason": "Use KafkaUtils#setConsumerRecordFormatter instead.",
"level": "error"
}
},
{ {
"name": "spring.kafka.listener.type", "name": "spring.kafka.listener.type",
"defaultValue": "single" "defaultValue": "single"

@ -432,17 +432,6 @@ class KafkaAutoConfigurationTests {
}); });
} }
@Test
@Deprecated
void logOnlyRecordMetadataProperty() {
this.contextRunner.withPropertyValues("spring.kafka.listener.only-log-record-metadata=true").run((context) -> {
AbstractKafkaListenerContainerFactory<?, ?, ?> kafkaListenerContainerFactory = (AbstractKafkaListenerContainerFactory<?, ?, ?>) context
.getBean(KafkaListenerContainerFactory.class);
ContainerProperties containerProperties = kafkaListenerContainerFactory.getContainerProperties();
assertThat(containerProperties.isOnlyLogRecordMetadata()).isTrue();
});
}
@Test @Test
void testKafkaTemplateRecordMessageConverters() { void testKafkaTemplateRecordMessageConverters() {
this.contextRunner.withUserConfiguration(MessageConverterConfiguration.class) this.contextRunner.withUserConfiguration(MessageConverterConfiguration.class)

@ -1,5 +1,5 @@
/* /*
* Copyright 2012-2021 the original author or authors. * Copyright 2012-2022 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -55,7 +55,6 @@ class KafkaPropertiesTests {
void listenerDefaultValuesAreConsistent() { void listenerDefaultValuesAreConsistent() {
ContainerProperties container = new ContainerProperties("test"); ContainerProperties container = new ContainerProperties("test");
Listener listenerProperties = new KafkaProperties().getListener(); Listener listenerProperties = new KafkaProperties().getListener();
assertThat(listenerProperties.isOnlyLogRecordMetadata()).isEqualTo(container.isOnlyLogRecordMetadata());
assertThat(listenerProperties.isMissingTopicsFatal()).isEqualTo(container.isMissingTopicsFatal()); assertThat(listenerProperties.isMissingTopicsFatal()).isEqualTo(container.isMissingTopicsFatal());
} }

Loading…
Cancel
Save