Skip to content

Commit 4f1c90e

Browse files
committed
Fix new Sonar issues
1 parent 9a21bcc commit 4f1c90e

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -536,11 +536,11 @@ public void close() {
536536
@SuppressWarnings("deprecation")
537537
@Deprecated
538538
public void close(long timeout, @Nullable TimeUnit unit) {
539-
close(Duration.ofMillis(unit.toMillis(timeout)));
539+
close(unit == null ? null : Duration.ofMillis(unit.toMillis(timeout)));
540540
}
541541

542542
@Override
543-
public void close(Duration timeout) {
543+
public void close(@Nullable Duration timeout) {
544544
if (this.cache != null) {
545545
if (this.txFailed) {
546546
if (logger.isWarnEnabled()) {

spring-kafka/src/main/java/org/springframework/kafka/core/KafkaAdmin.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ public class KafkaAdmin implements ApplicationContextAware, SmartInitializingSin
6565

6666
private static final int DEFAULT_OPERATION_TIMEOUT = 30;
6767

68-
private final static Log LOGGER = LogFactory.getLog(KafkaAdmin.class);
68+
private static final Log LOGGER = LogFactory.getLog(KafkaAdmin.class);
6969

7070
private final Map<String, Object> config;
7171

0 commit comments

Comments
 (0)