Google Functon通过spring-cloud-stream和spring-cloud-function接收来自Kafka的消息

Question

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

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

根据我的理解，我可以将Spring Cloud Stream和Spring Cloud Function结合起来。这是否意味着我可以使用Spring Cloud Stream中的绑定器来实际接受来自Kafka的消息？

Answer 1

Google Cloud Functions使用触发器模型来触发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