diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java index b266f56924..96407478f8 100644 --- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java +++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java @@ -72,9 +72,7 @@ public class KafkaInboundGatewaySpec extends MessagingGatewaySupport } /** - * Specify a {@link RetryTemplate} instance to wrap - * {@link KafkaInboundGateway.IntegrationRecordMessageListener} into - * {@code RetryingMessageListenerAdapter}. + * Specify a {@link RetryTemplate} instance to use for retrying deliveries. *

* IMPORTANT: This form of retry is blocking and could cause a rebalance if the * aggregate retry delays across all polled records might exceed the diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java index 818b0a7eb0..3c1301bcd6 100644 --- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java +++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java @@ -199,9 +199,7 @@ public class KafkaMessageDrivenChannelAdapter extends MessageProducerSuppo } /** - * Specify a {@link RetryTemplate} instance to wrap - * {@link KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener} into - * {@code RetryingMessageListenerAdapter}. + * Specify a {@link RetryTemplate} instance to use for retrying deliveries. *

* IMPORTANT: This form of retry is blocking and could cause a rebalance if the * aggregate retry delays across all polled records might exceed the @@ -231,16 +229,13 @@ public class KafkaMessageDrivenChannelAdapter extends MessageProducerSuppo } /** - * The {@code boolean} flag to specify the order how - * {@code RetryingMessageListenerAdapter} and - * {@link FilteringMessageListenerAdapter} are wrapped to each other, - * if both of them are present. + * The {@code boolean} flag to specify the order in which the filter and retry + * operations are performed. * Does not make sense if only one of {@link RetryTemplate} or - * {@link RecordFilterStrategy} is present, or any. + * {@link RecordFilterStrategy} is present, or none. * When true, the filter is called for each retry; when false, the filter is only * called once for each delivery from the container. - * @param filterInRetry the order for {@code RetryingMessageListenerAdapter} and - * {@link FilteringMessageListenerAdapter} wrapping. Defaults to {@code false}. + * @param filterInRetry true to filter for each retry. Defaults to {@code false}. */ public void setFilterInRetry(boolean filterInRetry) { this.filterInRetry = filterInRetry;