krallistic
krallistic
Linkedin opensourced cruise-control (https://github.com/linkedin/cruise-control) a tool to rebalance kafka-cluster. Since they have much more experience running kafka cluster, their algorithms should be used. As a first integration, the following steps...
Currently, some state is stored inside the pod annotation. This isn't really good practice and should the state filed inside the crd should be used.
Health check can be just when every component started (maybe use promhttp for that?) Readiness should be when CRD has been established and informer works.
It should be possible to add an ImagePullSecret and the possibility to pull from different repos.
Currently there is a quite some ugly bash code hacking in the kafka image to set advertised listener and broker id correctly. ``` Command: []string{"/bin/bash", "-c", fmt.Sprintf("export KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://$(hostname).%s.$(NAMESPACE).svc.cluster.local:9092; \n"+ "set...