我开始使用 Kubeflow,并且阅读了有关 KFServing 的信息。与 Kafka 有这种集成,可以从主题中消费。我需要运行一个推理管道,该管道使用来自 Kafka 的数据,进行一些数据预处理,运行 ML 预测,然后将结果发布回 Kafka,如下所示:
我知道我可以使用 Knative 事件从 Kafka 主题 1 摄取数据。有没有办法将 Kafka 用作接收器,或者我是否需要编写一个单独的容器将事件发布到 Kafka 主题 2?
谢谢!
我开始使用 Kubeflow,并且阅读了有关 KFServing 的信息。与 Kafka 有这种集成,可以从主题中消费。我需要运行一个推理管道,该管道使用来自 Kafka 的数据,进行一些数据预处理,运行 ML 预测,然后将结果发布回 Kafka,如下所示:
我知道我可以使用 Knative 事件从 Kafka 主题 1 摄取数据。有没有办法将 Kafka 用作接收器,或者我是否需要编写一个单独的容器将事件发布到 Kafka 主题 2?
谢谢!