GH-2985: Add Kafka Listener Container Customizer interfaces and docum… #3015
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
…es and documentation Resolves spring-cloud#2985 This commit introduces new customization options for Kafka listener containers in Spring Cloud Stream, along with comprehensive documentation: - Add KafkaListenerContainerCustomizer interface for Kafka-specific customization with access to extended consumer properties - Extend ListenerContainerWithDlqAndRetryCustomizer to include access to extended consumer properties - Update KafkaMessageChannelBinder to support the new customizer interfaces - Implement KafkaListenerContainerCustomizerTests for integration testing - Add detailed AsciiDoc reference documentation explaining the purpose, usage, and hierarchy of these customizer interfaces: * ListenerContainerCustomizer (existing) * KafkaListenerContainerCustomizer (new) * ListenerContainerWithDlqAndRetryCustomizer (extended) - Update navigation to include the new documentation These changes enhance the flexibility and configurability of Kafka consumer endpoints in Spring Cloud Stream applications, allowing users to fine-tune their listener containers based on specific requirements and scenarios, with improved access to Kafka-specific properties.
LukeKynaston
reviewed
Oct 7, 2024
| @EmbeddedKafka(partitions = 1, topics = "test-topic") | ||
| class KafkaListenerContainerCustomizerTests { | ||
|
|
||
| @Autowired |
There was a problem hiding this comment.
You could use the JSR-250 @resource annotation (jakarta.annotation.Resource)
https://docs.spring.io/spring-framework/reference/core/beans/annotation-config/resource.html
LukeKynaston
approved these changes
Oct 7, 2024
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
…entation
Resolves #2985
This commit introduces new customization options for Kafka listener containers in Spring Cloud Stream, along with comprehensive documentation:
These changes enhance the flexibility and configurability of Kafka consumer endpoints in Spring Cloud Stream applications, allowing users to fine-tune their listener containers based on specific requirements and scenarios, with improved access to Kafka-specific properties.