У меня есть rabbitmq, из которого каждое сообщение amqp потребляется работником сельдерея, и оно запускает работу приложения оператора спарка с использованием собственных REST API-интерфейсов kube. Теперь проблема в том, что все сообщения в rabbitmq предварительно выбираются рабочим из сельдерея и помещаются во внутренний рабочий оператора spark k8 Q. И я не могу отслеживать задания через spark-оператор. Вместо этого я хотел бы понять, можем ли мы лучше настроить оператор spark k8s с rabbitmq?