-
Notifications
You must be signed in to change notification settings - Fork 2.8k
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
Kafka configuration normalization #13889
Comments
SmallRye Reactive Messaging properties do not start with the quarkus prefix because they are defined in the Reactive Messaging specification. Regarding this issue, we should make the Kafka streams extension read the |
Yes I get that property keys are defined by SmallRye Reactive Messaging, but couldn't we provide "translation" from If I can help on this, please let me know. |
No, unfortunately, it's not that simple in this case. How reactive messaging (not smallrye, the spec) is a bit particular. We could prepend "quarkus." to all the properties, but that would only create longer keys. |
"kafka.bootstrap.servers" is the property used by the Reactive Messaging Kafka connector. Related to quarkusio#13889.
BTW, I just opened #14095 which allows Kafka Streams to be configured using |
Fixed by #14095. |
"kafka.bootstrap.servers" is the property used by the Reactive Messaging Kafka connector. Related to quarkusio#13889.
Describe the bug
Kafka configuration properties should be the same whatever the extension used.
Expected behavior
As of now, if you use the
smallrye-reactive-messaging-kafka
, the kafka host is configured through thekafka.bootstrap.servers
property, but if you use thequarkus-smallrye-reactive-messaging-kafka
, the you must usequarkus.kafka-streams.bootstrap-servers
property.If both extension are used, the configuration miust be duplicated which is error prone.
Actualy, none of the
quarkus-smallrye-reactive-messaging-kafka
properties starts withquarkus
which seems odd to me.Actual behavior
Configuration property keys should be normalized.
The text was updated successfully, but these errors were encountered: