Я начинаю использовать Kubeflow и читал о KFServing. Есть эта интеграция с Kafka, чтобы потреблять из темы. Мне нужно запустить конвейер вывода, который потребляет данные из Kafka, выполняет некоторую предварительную обработку данных, запускает прогноз машинного обучения, а затем публикует результат обратно в Kafka, например:
Я знаю, что могу использовать Knative eventing для приема данных из темы Kafka 1. Есть ли способ использовать Kafka в качестве приемника, или мне нужно написать отдельный контейнер, который публикует события в теме Kafka 2?
Спасибо!
