0

我知道使用 Kafka Connect 您可以创建连接器将所有 kafka 消息接收到 PUBSUB 主题。

我想知道我是否可以将 Spring Cloud Stream 绑定器与 Spring Cloud Function 结合使用并将所有这些部署到 Google Functions。

在我理解正确的情况下,我可以结合 Spring Cloud Stream 和 Spring Cloud Function。这是否意味着我可以使用 Spring Cloud Stream 的 binder 来实际接受来自 Kafka 的消息?

4

1 回答 1

0

Google Cloud Functions 使用 Trigger 模型来触发 spring-cloud-function 中的函数。不支持将 Kafka 作为触发器。

解决方法是创建使用 Kafka Connect 从 Kafka 主题提供 PUBSUB。您可以创建自己的: https ://dev.to/vtatai/make-kafka-serverless-by-connecting-it-to-google-cloud-functions-2ahh

或使用提供的: https ://github.com/GoogleCloudPlatform/pubsub/tree/master/kafka-connector

于 2020-09-16T08:16:44.133 回答