我知道使用kafka connect可以创建连接器，将所有kafka消息接收到一个子主题。
我想知道我是否可以将springcloud流绑定器与springcloud函数结合使用，并将所有这些部署到google函数中。
在我理解正确的情况下，我可以将spring云流和spring云函数结合起来。这是否意味着我可以使用springcloudstream的活页夹实际地接受kafka的消息？
我知道使用kafka connect可以创建连接器，将所有kafka消息接收到一个子主题。
我想知道我是否可以将springcloud流绑定器与springcloud函数结合使用，并将所有这些部署到google函数中。
在我理解正确的情况下，我可以将spring云流和spring云函数结合起来。这是否意味着我可以使用springcloudstream的活页夹实际地接受kafka的消息？
1条答案
按热度按时间envsm3lx1#
googlecloud函数使用一个触发器模型来触发spring cloud函数中的函数。不支持将kafka用作触发器。
解决方法是使用kafka connect从kafka主题创建feed 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