From 90797aa969e69d9261b7539cb1e3f77e8284894c Mon Sep 17 00:00:00 2001 From: Chanhyeong Cho Date: Tue, 29 Nov 2022 02:17:32 +0900 Subject: [PATCH] Fix documentation in kafka.adoc Remove copy/paste artifact from JavaDocs. --- src/reference/asciidoc/kafka.adoc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/reference/asciidoc/kafka.adoc b/src/reference/asciidoc/kafka.adoc index 2b90c89beb..4322fdde09 100644 --- a/src/reference/asciidoc/kafka.adoc +++ b/src/reference/asciidoc/kafka.adoc @@ -225,7 +225,7 @@ You can also use the `recovery-callback` to specify some other action to take in When building an `ErrorMessage` (for use in the `error-channel` or `recovery-callback`), you can customize the error message by setting the `error-message-strategy` property. By default, a `RawRecordHeaderErrorMessageStrategy` is used, to provide access to the converted message as well as the raw `ConsumerRecord`. -IMPORTANT: This form of retry is blocking and could cause a rebalance if the aggregate retry delays across all polled records might exceed the `{@code `max.poll.interval.ms` consumer property. +IMPORTANT: This form of retry is blocking and could cause a rebalance if the aggregate retry delays across all polled records might exceed the `max.poll.interval.ms` consumer property. Instead, consider adding a `DefaultErrorHandler` to the listener container, configured with a `KafkaErrorSendingMessageRecoverer`. [[kafka-inbound-adapter-configuration]] @@ -577,7 +577,7 @@ You can also use the `recovery-callback` to specify some other action to take in When building an `ErrorMessage` (for use in the `error-channel` or `recovery-callback`), you can customize the error message by setting the `error-message-strategy` property. By default, a `RawRecordHeaderErrorMessageStrategy` is used, to provide access to the converted message as well as the raw `ConsumerRecord`. -IMPORTANT: This form of retry is blocking and could cause a rebalance if the aggregate retry delays across all polled records might exceed the `{@code `max.poll.interval.ms` consumer property. +IMPORTANT: This form of retry is blocking and could cause a rebalance if the aggregate retry delays across all polled records might exceed the `max.poll.interval.ms` consumer property. Instead, consider adding a `DefaultErrorHandler` to the listener container, configured with a `KafkaErrorSendingMessageRecoverer`. The following example shows how to configure a simple upper case converter with the Java DSL: