in pkg/controller/broker/broker_controller.go [405:412]
func isReady(po corev1.Pod) bool { for _, cond := range po.Status.Conditions { if cond.Type == corev1.PodReady { return cond.Status == corev1.ConditionTrue } } return false }