The kas-fleetshard-operator is responsible for provisioning and managing instances of kafka on a cluster. The kas-fleetshard-synchronizer synchronizes the state of a fleet shard with the kas-fleet-manager.
Apache License 2.0
7
stars
20
forks
source link
a follow up to #734 - allowing the fleetshard to set annotations #735
Our logic to detect changes and retain data plane annotations needed refinement.
We can't compare the entire metadata as that will look not only at all annotations, but at the kubernetes internal metadata fields - so the previous version was effectively always returning true.
Then to properly account for annotations managed by the data plane vs those maintained by the control plane we need to maintain a set of what we might add / change and then account for that in the change detection and in the update to the local managedkafka.
Our logic to detect changes and retain data plane annotations needed refinement.
We can't compare the entire metadata as that will look not only at all annotations, but at the kubernetes internal metadata fields - so the previous version was effectively always returning true.
Then to properly account for annotations managed by the data plane vs those maintained by the control plane we need to maintain a set of what we might add / change and then account for that in the change detection and in the update to the local managedkafka.