Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-3916: Delete redundant null check

Browse Source 
Fixes: https://github.com/spring-projects/spring-kafka/pull/3916

Delete redundant null check

Signed-off-by: JaeYeon Kim <ghgh415263@naver.com>
This commit is contained in:
Kim JaeYeon
2025-05-23 01:54:22 +09:00
committed by GitHub
parent ec154a3b6a
commit cff92363f8
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java
View File

@@ -116,6 +116,7 @@ import org.springframework.util.StringUtils;
* @author Thomas Strauß
* @author Adrian Gygax
* @author Soby Chacko
* @author Jaeyeon Kim
*/
public class DefaultKafkaProducerFactory<K, V> extends KafkaResourceFactory
implements ProducerFactory<K, V>, ApplicationContextAware,
@@ -1181,13 +1182,11 @@ public class DefaultKafkaProducerFactory<K, V> extends KafkaResourceFactory
@Override
public void abortTransaction() throws ProducerFencedException {
LOGGER.debug(() -> toString() + " abortTransaction()");
if (this.producerFailed != null) {
LOGGER.debug(() -> {
String message = this.producerFailed == null ? "" : this.producerFailed.getMessage();
return "abortTransaction ignored - previous txFailed: " + message
+ ": " + this;
});
Exception producerFailedToUse = this.producerFailed;
LOGGER.debug(() -> this + " abortTransaction()");
if (producerFailedToUse != null) {
LOGGER.debug(() -> "abortTransaction ignored - previous txFailed: " + producerFailedToUse.getMessage()
+ ": " + this);
}
else {
try {