It turns out that typeis the right field to use when pulling from the status of a Kafka resource in Strimzi. I was confused because I was looking at pulling it from the spec of a Kafka resource. For historical reasons, type is used to denote the name of the listener in the status of a Kafka custom resource.
So, the existing code was totally valid - it just only works if the internal listener is named tls. This change makes that configurable.
Along the way, I fixed the pytest-flake8 CI bug, and updated the CRD to include a spec.
This is the v2 of #10.
It turns out that
typeis the right field to use when pulling from thestatusof a Kafka resource in Strimzi. I was confused because I was looking at pulling it from thespecof a Kafka resource. For historical reasons,typeis used to denote the name of the listener in the status of a Kafka custom resource.So, the existing code was totally valid - it just only works if the internal listener is named
tls. This change makes that configurable.Along the way, I fixed the pytest-flake8 CI bug, and updated the CRD to include a spec.