-
Notifications
You must be signed in to change notification settings - Fork 1.6k
Change @RetryableTopic properties SameIntervalTopicReuseStrategy behavior to SINGLE_TOPIC #3058
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
This comment was marked as resolved.
This comment was marked as resolved.
* -retry-16000-1 | ||
* -retry-16000-2 | ||
* ... | ||
* -retry-16000-224 | ||
|
||
[source, java] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We might want to add a short sentence stating that the following code snippet is changing the default behavior - something like If multiple topics are required, then that can be done using the following configuration.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks, fix it.
@@ -16,8 +16,8 @@ IMPORTANT: You can set the `AckMode` mode you prefer, but `RECORD` is suggested. | |||
IMPORTANT: At this time this functionality doesn't support class level `@KafkaListener` annotations. | |||
|
|||
When using a manual `AckMode` with `asyncAcks` set to true, the `DefaultErrorHandler` must be configured with `seekAfterError` set to `false`. | |||
Starting with versions 2.9.10, 3.0.8, this will be set to true unconditionally for such configurations. | |||
With earlier versions, it was necessary to override the `RetryConfigurationSupport.configureCustomizers()` method to set the property to `true`. | |||
Starting with versions 2.9.10, 3.0.8, this will be set to `false` unconditionally for such configurations. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Was it false
in those releases?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
[[x32-retry-topic]] | ||
=== Change @RetryableTopic SameIntervalTopicReuseStrategy default value | ||
Change `@RetryableTopic` property SameIntervalTopicReuseStrategy default value to SINGLE_TOPIC. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Code formatting needed for SameIntervalTopicReuseStrategy
and SINGLE_TOPIC.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thanks, fix it.
* Change @RetryableTopic properties SameIntervalTopicReuseStrategy behavior to SINGLE_TOPIC. * Change unit test SameIntervalTopicReuseStrategy. * Add doc.
Resolves #3052