kafka-operator
kafka-operator copied to clipboard
krallistic
A Kafka Operator for Kubernetes
I know you're aware of the project, but has anyone successfully combined your operator (with Cruise Control, yay!) with the [Yolean/kubernetes-kafka](https://github.com/Yolean/kubernetes-kafka) base? There's a bit of a disconnect, but I...
The value for the `storageClass` spec option is completely ignored, and instead the operator produces PVCs with a 'standard' storage class. ```yaml kind: Kafkacluster apiVersion: krallistic.github.com/v1 metadata: name: kafka spec:...
Basically I run the operator, add the cluster CRD (with confluentinc/cp-kafka 3.3.0), and then the operator (0.2.0) creates the statefulset ... and crashes right after it. ~~~~ time="2017-10-26T15:22:08Z" level=info msg="New...
https://github.com/krallistic/kafka-operator/blob/master/controller/crd.go#L97 specifically checks all namespaces for CRD instances. In my case I rather have the operator only look-at/touch a single namespace.
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.