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
Change listeners configuration to list to allow for more listeners #3603
Change listeners configuration to list to allow for more listeners #3603
Conversation
/azp run acceptance |
Azure Pipelines successfully started running 1 pipeline(s). |
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/ArrayOrObjectKafkaListeners.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/ArrayOrObjectKafkaListeners.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/ArrayOrObjectKafkaListeners.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/ArrayOrObjectKafkaListeners.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/ArrayOrObjectKafkaListeners.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/ArrayOrObjectKafkaListeners.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/KafkaListenerType.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/ListenersConvertor.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/ListenersConvertor.java
Outdated
Show resolved
Hide resolved
...perator/src/main/java/io/strimzi/operator/cluster/model/KafkaBrokerConfigurationBuilder.java
Outdated
Show resolved
Hide resolved
cluster-operator/src/main/java/io/strimzi/operator/cluster/model/KafkaCluster.java
Show resolved
Hide resolved
public void serialize(ArrayOrObjectKafkaListeners value, JsonGenerator generator, SerializerProvider provider) throws IOException { | ||
if (value != null) { | ||
if (value.listValue != null) { | ||
generator.writeObject(value.listValue); |
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 write an object for the list value?
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.
Yes. This is one of the chaotic things where Object here is Java Object and not YAML / JSON Object :-(.
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/GenericKafkaListener.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/GenericKafkaListener.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/GenericKafkaListener.java
Outdated
Show resolved
Hide resolved
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/GenericKafkaListener.java
Outdated
Show resolved
Hide resolved
cluster-operator/src/main/java/io/strimzi/operator/cluster/model/ListenersValidator.java
Outdated
Show resolved
Hide resolved
cluster-operator/src/main/java/io/strimzi/operator/cluster/model/ListenersValidator.java
Outdated
Show resolved
Hide resolved
cluster-operator/src/main/java/io/strimzi/operator/cluster/model/ListenersValidator.java
Outdated
Show resolved
Hide resolved
cluster-operator/src/main/java/io/strimzi/operator/cluster/model/ListenersValidator.java
Outdated
Show resolved
Hide resolved
.../java/io/strimzi/operator/cluster/operator/assembly/KafkaAssemblyOperatorCustomCertTest.java
Show resolved
Hide resolved
/azp run acceptance |
Pull request contains merge conflicts. |
ffc8c7f
to
02b4b0c
Compare
/azp run acceptance |
Azure Pipelines successfully started running 1 pipeline(s). |
/azp run acceptance |
Azure Pipelines successfully started running 1 pipeline(s). |
/azp run regression |
Azure Pipelines successfully started running 1 pipeline(s). |
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.
Good work I had a first pass.
api/src/main/java/io/strimzi/api/kafka/model/listener/v2/ArrayOrObjectKafkaListeners.java
Outdated
Show resolved
Hide resolved
cluster-operator/src/main/java/io/strimzi/operator/cluster/model/ListenersUtils.java
Show resolved
Hide resolved
/azp run acceptance |
Azure Pipelines successfully started running 1 pipeline(s). |
/azp run regression |
Azure Pipelines successfully started running 1 pipeline(s). |
@strimzi-ci run tests |
❌ Test Summary ❌TEST_PROFILE: acceptance Re-run command: |
@strimzi-ci run tests false profile=acceptance testcase=io.strimzi.systemtest.bridge.HttpBridgeKafkaExternalListenersST#testTlsAuthWithWeirdUsername |
✔️ Test Summary ✔️TEST_PROFILE: acceptance |
@strimzi-ci run tests false profile=acceptance testcase=io.strimzi.systemtest.kafka.BackwardsCompatibleListenersST |
@tombentley @samuel-hawker @ppatierno @Frawless I changed this from Draft to regular PR and I think this should now be ready for the final review. Thanks |
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
Signed-off-by: Jakub Scholz <www@scholzj.com>
7250109
to
c606555
Compare
/azp run acceptance |
Azure Pipelines successfully started running 1 pipeline(s). |
@strimzi-ci run tests |
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.
Great work!
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.
Great work!
Signed-off-by: Jakub Scholz <www@scholzj.com>
...ava/io/strimzi/api/kafka/model/listener/arraylistener/GenericKafkaListenerConfiguration.java
Show resolved
Hide resolved
/azp run regression |
Azure Pipelines successfully started running 1 pipeline(s). |
/azp run acceptance |
Azure Pipelines successfully started running 1 pipeline(s). |
✔️ Test Summary ✔️TEST_PROFILE: acceptance ❗ Test Failures ❗
|
Type of change
Description
This PR implements the Strimzi Proposal no 5 and brings the possibility to configure listeners as a list and allow to configure more listeners at the same time.
Compared to the proposal, the internal listener type is now
internal
sinceservice
seemed a bit too confusing (all listeners use some services). Since all listeners now use the same API objects, there is now a new class for validation to check all kinds of different parameters and ensure only the compatible fields are used. But this also allows to use a lot of new configuration combinations which were not possible in the past because they were not implemented. That includes for example advertised host and port configuration for all listeners etc. I also merged theoverride
andconfiguration
sections which were confusing and had a big overlap in the past API. Additionally, I added option to use fully qualified service names in internal listeners as requested by some users (has to be enabled - #2656).There is also a convertor which converts the old API to the new API for backwards compatibility. There are also several methods which take care of using the right names for the old listeners to not change listener names in Kafka or service names in Kube since that would change all addresses etc.
PS: Sorry for the big PR ... I really was trying to find ways how to split it into smaller PRs. But I do not think it was really possible here.
Checklist