Skip to content

Commit 4d90f72

Browse files
remove 'dead links' in javadocs
1 parent f768874 commit 4d90f72

14 files changed

+16
-26
lines changed

spring-kafka/src/main/java/org/springframework/kafka/annotation/RetryableTopic.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -181,10 +181,6 @@
181181

182182
/**
183183
* Topic reuse strategy for sequential attempts made with a same backoff interval.
184-
*
185-
* <p>Note: for fixed backoffs, when this is configured as
186-
* {@link SameIntervalTopicReuseStrategy#SINGLE_TOPIC}, it has precedence over
187-
* the configuration in {@link #fixedDelayTopicStrategy()}.
188184
* @return the strategy.
189185
* @since 3.0.4
190186
*/

spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -226,8 +226,9 @@ public void setReplyTemplate(KafkaTemplate<?, ?> replyTemplate) {
226226

227227
/**
228228
* Set the {@link CommonErrorHandler} which can handle errors for both record and
229-
* batch listeners. Replaces the use of
230-
* {@link org.springframework.kafka.listener.GenericErrorHandler}s.
229+
* batch listeners. Replaces the use of <a href="https://javadoc.io/doc/org.springframework.kafka/
230+
* spring-kafka/latest/org/springframework/kafka/3.0.12/CommonErrorHandler.html">
231+
* {@code org.springframework.kafka.listener.GenericErrorHandler}</a>s.
231232
* @param commonErrorHandler the handler.
232233
* @since 2.8
233234
*/

spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -193,8 +193,7 @@ public void setStateListener(KafkaStreams.StateListener stateListener) {
193193
}
194194

195195
/**
196-
* Set a {@link StreamsUncaughtExceptionHandler}. Supersedes
197-
* {@link #setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler)}.
196+
* Set a {@link StreamsUncaughtExceptionHandler}.
198197
* @param streamsUncaughtExceptionHandler the handler.
199198
* @since 2.8
200199
*/

spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -234,7 +234,9 @@ public CommonErrorHandler getCommonErrorHandler() {
234234

235235
/**
236236
* Set the {@link CommonErrorHandler} which can handle errors for both record
237-
* and batch listeners. Replaces the use of {@link GenericErrorHandler}s.
237+
* and batch listeners. Replaces the use of <a href="https://javadoc.io/doc/org.springframework.kafka/
238+
* spring-kafka/latest/org/springframework/kafka/3.0.12/CommonErrorHandler.html">
239+
* {@code org.springframework.kafka.listener.GenericErrorHandler}</a>s.
238240
* @param commonErrorHandler the handler.
239241
* @since 2.8
240242
*/

spring-kafka/src/main/java/org/springframework/kafka/listener/CommonErrorHandler.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,10 @@
3030
import org.springframework.kafka.support.TopicPartitionOffset;
3131

3232
/**
33-
* Replacement for {@link ErrorHandler} and {@link BatchErrorHandler} and their
33+
* Replacement for <a href="https://javadoc.io/doc/org.springframework.kafka/
34+
* spring-kafka/3.0.12/org/springframework/kafka/listener/ErrorHandler.html">{@code ErrorHandler}</a>
35+
* and <a href="https://javadoc.io/doc/org.springframework.kafka/spring-kafka/
36+
* 3.0.12/org/springframework/kafka/listener/BatchErrorHandler.html">{@code BatchErrorHandler}</a> and their
3437
* sub-interfaces.
3538
*
3639
* @author Gary Russell

spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2717,7 +2717,8 @@ private void pauseForNackSleep() {
27172717
* Actually invoke the listener.
27182718
* @param cRecord the record.
27192719
* @param iterator the {@link ConsumerRecords} iterator - used only if a
2720-
* {@link RemainingRecordsErrorHandler} is being used.
2720+
* <a href="https://javadoc.io/doc/org.springframework.kafka/spring-kafka/3.0.12/org/springframework/
2721+
* kafka/listener/RemainingRecordsErrorHandler.html">{@code RemainingRecordsErrorHandler}</a> is being used.
27212722
* @return an exception.
27222723
* @throws Error an error.
27232724
*/

spring-kafka/src/main/java/org/springframework/kafka/retrytopic/DestinationTopicContainer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public interface DestinationTopicContainer {
5252
* be forwarded to, since that depends on different factors.
5353
*
5454
* If you need to find out the exact next topic for a message use the
55-
* {@link DestinationTopicResolver#resolveDestinationTopic(String, Integer, Exception, long)}
55+
* {@link DestinationTopicResolver#resolveDestinationTopic(String, String, Integer, Exception, long)}
5656
* method instead.
5757
* @param mainListenerId the listener id.
5858
* @param topicName the topic name of the DestinationTopic to be returned.

spring-kafka/src/main/java/org/springframework/kafka/retrytopic/RetryTopicConfigurationBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,7 @@ public RetryTopicConfigurationBuilder setTopicSuffixingStrategy(TopicSuffixingSt
247247
* <p>Note: for fixed backoffs, when this is configured as
248248
* {@link SameIntervalTopicReuseStrategy#SINGLE_TOPIC}, it has precedence over
249249
* the configuration done through
250-
* {@link #useSingleTopicForFixedDelays(FixedDelayStrategy)}.
250+
* {@link #useSingleTopicForSameIntervals()}.
251251
* @param sameIntervalTopicReuseStrategy the strategy.
252252
* @return the builder.
253253
* @since 3.0.4

spring-kafka/src/test/java/org/springframework/kafka/listener/CommonContainerStoppingErrorHandler1Tests.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -61,9 +61,6 @@
6161
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
6262

6363
/**
64-
* Copied from {@link ContainerStoppingErrorHandlerRecordModeTests} with a new error
65-
* handler.
66-
*
6764
* @author Gary Russell
6865
* @since 2.8
6966
*

spring-kafka/src/test/java/org/springframework/kafka/listener/CommonContainerStoppingErrorHandler2Tests.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -59,9 +59,6 @@
5959
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
6060

6161
/**
62-
* Copied from {@link ContainerStoppingErrorHandlerBatchModeTests} with a new error
63-
* handler.
64-
*
6562
* @author Gary Russell
6663
* @since 2.8
6764
*

0 commit comments

Comments
 (0)