首页 > 解决方案 > Kafkalistener 作为无服务器或功能

问题描述

我们有一个 Kafka 监听器从主题中消费消息。我们想让这个 bean 成为函数式的,这样当负载很重时,我们可以使用无服务器架构启动多个函数实例。谁能告诉我正确的方向

标签: spring-kafkaspring-cloud-streamspring-cloud-functionspring-cloud-stream-binder-kafka

解决方案


看看Spring Cloud Stream Function 支持。您可以将它与 Kafka 活页夹一起使用。

在上一篇文章中,我试图为我们转向 Spring Cloud Stream (SCSt) 中的函数式编程模型提供理由。它的代码更少,配置更少。不过,最重要的是,您的代码与 SCSt 的内部完全解耦并独立。

在这篇文章中,我将深入挖掘并总结我们功能支持的核心特性,特别是围绕它的反应特性。


推荐阅读