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