apache-kafka - 是否可以让 Kubeflow 推理管道 (KFServing) 将消息发布到 Kafka？

Question

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

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

谢谢！

标签： apache-kafkakubeflowkubeflow-pipelinesknative-eventing

Answer 1

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