Skip to content

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

Merged
merged 2 commits into from
Feb 29, 2024

Conversation

Wzy19930507
Copy link
Contributor

Resolves #3052

  • Change @RetryableTopic properties SameIntervalTopicReuseStrategy behavior to SINGLE_TOPIC
  • Change unit test SameIntervalTopicReuseStrategy
  • Add doc

@Wzy19930507

This comment was marked as resolved.

* -retry-16000-1
* -retry-16000-2
* ...
* -retry-16000-224

[source, java]
Copy link
Contributor

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.

Copy link
Contributor Author

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.
Copy link
Contributor

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?

Copy link
Contributor Author

@Wzy19930507 Wzy19930507 Feb 29, 2024

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yes, when using a manual AckMode with asyncAcks set to true, will unconditionally set to false,
see #2707 and #2702.

[[x32-retry-topic]]
=== Change @RetryableTopic SameIntervalTopicReuseStrategy default value
Change `@RetryableTopic` property SameIntervalTopicReuseStrategy default value to SINGLE_TOPIC.
Copy link
Contributor

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.

Copy link
Contributor Author

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.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Change @RetryableTopic properties SameIntervalTopicReuseStrategy behavior to SINGLE_TOPIC
2 participants