Google Functons通过spring-cloud-stream和spring-cloud-functions从Kafka接收消息

问题描述

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

我想知道我是否可以结合使用Spring Cloud Stream活页夹和Spring Cloud Function,并将其全部部署到Google Functions。

据我所知,我可以结合使用Spring Cloud Stream和Spring Cloud Function。这是否意味着我可以使用Spring Cloud Stream中的活页夹实际上接受来自Kafka的消息?

解决方法

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