-
Notifications
You must be signed in to change notification settings - Fork 106
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
Introduce KafkaListener.threadsValue
to allow for dynamic config
#769
Introduce KafkaListener.threadsValue
to allow for dynamic config
#769
Conversation
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.
Looks good, though it is a breaking change as noted.
If we don't want to force another major version bump for something this simple, an alternate approach would be to keep the existing attribute as an int
and add an alternate attribute to the annotation that is a String
.
@sdelamo What do you think?
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 cannot do a breaking change now. Too late. either we search for a workaround or we do it for the next major version of Micronaut Kafka
I would keep it as an int and introduce |
KafkaListener.threads
as a String
to allow for dynamic configKafkaListener.threadsValue
to allow for dynamic config
kafka/src/test/groovy/io/micronaut/configuration/kafka/annotation/KafkaListenerSpec.groovy
Show resolved
Hide resolved
kafka/src/main/java/io/micronaut/configuration/kafka/processor/KafkaConsumerProcessor.java
Outdated
Show resolved
Hide resolved
We use only one field to read the value
Closes #689