Skip to content
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

@RetryableTopic support @KafkaListener annotated on class part 1 #3107

Merged
merged 3 commits into from
Mar 8, 2024

Conversation

Wzy19930507
Copy link
Contributor

  • @RetryableTopic support annotated on Class.
  • Support process @RetryableTopic from Class in RetryTopicConfigurationProvider.
  • Support process @DltHandler when @RetryableTopic annotated on the Class in RetryableTopicAnnotationProcessor.

part of #3105

}

@Nullable
public RetryTopicConfiguration findRetryConfigurationFor(String[] topics, @Nullable Method method,
Copy link
Contributor

Choose a reason for hiding this comment

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

Why does it need to be public? If it's valid, add the since tag and a note in whats-new as this is a new public API.

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Fix it.

* Support process `@RetryableTopic` from Class in `RetryTopicConfigurationProvider`.
* Support process `@DltHandler` when `@RetryableTopic` annotated on the Class in `RetryableTopicAnnotationProcessor`.

part of spring-projects#3105
@Wzy19930507 Wzy19930507 changed the title @RetryableTopic support @KafkaListener annotated on class part 1 @RetryableTopic support @KafkaListener annotated on class part 1 Mar 8, 2024
@sobychacko sobychacko added this to the 3.2.0-M2 milestone Mar 8, 2024
@sobychacko sobychacko merged commit 9571bab into spring-projects:main Mar 8, 2024
3 checks passed
@Wzy19930507 Wzy19930507 deleted the GH-3012_part_1 branch March 8, 2024 19:29
sobychacko pushed a commit that referenced this pull request Mar 18, 2024
Fixes: #3012 

* Non-blocking retries support for `@KafkaListener` on class level, which includes `@RetryableTopic,` `@DltHandler,` `RetryTopicConfiguration,` and `RetryTopicConfigurationSupport.`
* Doc and test for Non-blocking retries support for @KafkaListener on class level.
* Addressing PR review. 

See these earlier related PRs:

#3112
#3107
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants