Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -181,10 +181,6 @@

/**
* Topic reuse strategy for sequential attempts made with a same backoff interval.
*
* <p>Note: for fixed backoffs, when this is configured as
* {@link SameIntervalTopicReuseStrategy#SINGLE_TOPIC}, it has precedence over
* the configuration in {@link #fixedDelayTopicStrategy()}.
* @return the strategy.
* @since 3.0.4
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -226,8 +226,7 @@ public void setReplyTemplate(KafkaTemplate<?, ?> replyTemplate) {

/**
* Set the {@link CommonErrorHandler} which can handle errors for both record and
* batch listeners. Replaces the use of
* {@link org.springframework.kafka.listener.GenericErrorHandler}s.
* batch listeners.
* @param commonErrorHandler the handler.
* @since 2.8
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -193,8 +193,7 @@ public void setStateListener(KafkaStreams.StateListener stateListener) {
}

/**
* Set a {@link StreamsUncaughtExceptionHandler}. Supersedes
* {@link #setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler)}.
* Set a {@link StreamsUncaughtExceptionHandler}.
* @param streamsUncaughtExceptionHandler the handler.
* @since 2.8
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -234,7 +234,7 @@ public CommonErrorHandler getCommonErrorHandler() {

/**
* Set the {@link CommonErrorHandler} which can handle errors for both record
* and batch listeners. Replaces the use of {@link GenericErrorHandler}s.
* and batch listeners.
* @param commonErrorHandler the handler.
* @since 2.8
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,7 @@
import org.springframework.kafka.support.TopicPartitionOffset;

/**
* Replacement for {@link ErrorHandler} and {@link BatchErrorHandler} and their
* sub-interfaces.
* Listener container error handling contract.
*
* @author Gary Russell
* @since 2.8
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2716,8 +2716,7 @@ private void pauseForNackSleep() {
/**
* Actually invoke the listener.
* @param cRecord the record.
* @param iterator the {@link ConsumerRecords} iterator - used only if a
* {@link RemainingRecordsErrorHandler} is being used.
* @param iterator the {@link ConsumerRecords} iterator.
* @return an exception.
* @throws Error an error.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ public interface DestinationTopicContainer {
* be forwarded to, since that depends on different factors.
*
* If you need to find out the exact next topic for a message use the
* {@link DestinationTopicResolver#resolveDestinationTopic(String, Integer, Exception, long)}
* {@link DestinationTopicResolver#resolveDestinationTopic(String, String, Integer, Exception, long)}
* method instead.
* @param mainListenerId the listener id.
* @param topicName the topic name of the DestinationTopic to be returned.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -247,7 +247,7 @@ public RetryTopicConfigurationBuilder setTopicSuffixingStrategy(TopicSuffixingSt
* <p>Note: for fixed backoffs, when this is configured as
* {@link SameIntervalTopicReuseStrategy#SINGLE_TOPIC}, it has precedence over
* the configuration done through
* {@link #useSingleTopicForFixedDelays(FixedDelayStrategy)}.
* {@link #useSingleTopicForSameIntervals()}.
* @param sameIntervalTopicReuseStrategy the strategy.
* @return the builder.
* @since 3.0.4
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,9 +61,6 @@
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;

/**
* Copied from {@link ContainerStoppingErrorHandlerRecordModeTests} with a new error
* handler.
*
* @author Gary Russell
* @since 2.8
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,9 +59,6 @@
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;

/**
* Copied from {@link ContainerStoppingErrorHandlerBatchModeTests} with a new error
* handler.
*
* @author Gary Russell
* @since 2.8
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,9 +60,6 @@
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;

/**
* Copied from {@link ContainerStoppingBatchErrorHandlerTests} with a new error
* handler.
*
* @author Gary Russell
* @since 2.8
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,8 +47,7 @@
import org.springframework.util.backoff.FixedBackOff;

/**
* {@link DefaultErrorHandler} tests for batch listeners. Copied from
* {@link RecoveringBatchErrorHandlerIntegrationTests} changing error handler type.
* {@link DefaultErrorHandler} tests for batch listeners.
* @author Gary Russell
* @since 2.8
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,6 @@

/**
* {@link DefaultErrorHandler} tests for batch listeners.
* Copied from {@link RecoveringBatchErrorHandlerTests} replacing error handler type.
*
* @author Gary Russell
* @since 2.8
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,6 @@

/**
* {@link DefaultErrorHandler} tests for record listeners.
* Copied from {@link SeekToCurrentErrorHandlerTests} changing the error handler type.
*
* @author Gary Russell
* @since 2.8
Expand Down