2

我开始使用 Kubeflow,并且阅读了有关 KFServing 的信息。与 Kafka 有这种集成,可以从主题中消费。我需要运行一个推理管道,该管道使用来自 Kafka 的数据,进行一些数据预处理,运行 ML 预测,然后将结果发布回 Kafka,如下所示:

在此处输入图像描述

我知道我可以使用 Knative 事件从 Kafka 主题 1 摄取数据。有没有办法将 Kafka 用作接收器,或者我是否需要编写一个单独的容器将事件发布到 Kafka 主题 2?

谢谢!

4

2 回答 2

1

Knative Eventing 中有一个新KafkaSink资源,您可以使用它来将 CloudEvents 发布到 Kafka 主题,方法是将它们发送到状态中公开的 HTTP 地址。

于 2021-01-25T16:47:19.677 回答
0

@openroy 在 50:33 的这段视频中,演讲者说服务(如 KFServing)可以将 HTTP 响应返回到回复通道。

于 2020-05-07T05:55:35.057 回答