Skip to content

Commit 58d36c4

Browse files
committed
address compile warning
related to #10083 Signed-off-by: Jiandong Ma <[email protected]>
1 parent 10e83cc commit 58d36c4

File tree

3 files changed

+7
-4
lines changed

3 files changed

+7
-4
lines changed

spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaTemplateSpec.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2018-2023 the original author or authors.
2+
* Copyright 2018-2025 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -16,12 +16,13 @@
1616

1717
package org.springframework.integration.kafka.dsl;
1818

19+
import org.jspecify.annotations.Nullable;
20+
1921
import org.springframework.integration.dsl.IntegrationComponentSpec;
2022
import org.springframework.kafka.core.KafkaTemplate;
2123
import org.springframework.kafka.core.ProducerFactory;
2224
import org.springframework.kafka.support.ProducerListener;
2325
import org.springframework.kafka.support.converter.RecordMessageConverter;
24-
import org.springframework.lang.Nullable;
2526

2627
/**
2728
* An {@link IntegrationComponentSpec} implementation for the {@link KafkaTemplate}.

spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/RawRecordHeaderErrorMessageStrategy.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2017-2019 the original author or authors.
2+
* Copyright 2017-2025 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -19,12 +19,13 @@
1919
import java.util.HashMap;
2020
import java.util.Map;
2121

22+
import org.jspecify.annotations.Nullable;
23+
2224
import org.springframework.core.AttributeAccessor;
2325
import org.springframework.integration.IntegrationMessageHeaderAccessor;
2426
import org.springframework.integration.support.ErrorMessageStrategy;
2527
import org.springframework.integration.support.ErrorMessageUtils;
2628
import org.springframework.kafka.support.KafkaHeaders;
27-
import org.springframework.lang.Nullable;
2829
import org.springframework.messaging.Message;
2930
import org.springframework.messaging.support.ErrorMessage;
3031

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
/**
22
* Provides support classes.
33
*/
4+
@org.jspecify.annotations.NullMarked
45
package org.springframework.integration.kafka.support;

0 commit comments

Comments
 (0)