spring-boot - Spring Boot 完全反应式 Kafka 处理
问题描述
Spring Boot 生态系统中是否有任何完全反应式、生产就绪的 Kafka 支持?完全反应式是指尊重背压/轮询、并发消息处理(flatMap)和处理可能的故障(无序处理错误)。我做了我的研究,有几个有前途的选择(spring-cloud-stream
基于反应器的spring-cloud-function
支持,spring-integration
有KafkaMessageSource
和Reactor Kafka
项目),但我不确定它们是否满足所有要求,这实际上有点令人困惑。
解决方案
推荐阅读
- flutter - 将非标量变量设置为 null 并返回它在单个语句中引用的任何内容?
- python - 如何在 Clickhouse-driver 中获取 JSON 格式的数据
- angular - Angular ng-select - bindValue 不起作用,仍然绑定到整个对象
- python - 间歇性'NoAuthHandlerFound' boto 错误 | django + kinesis 客户端
- c# - 内存映射文件是否支持 uwp 应用程序和 win32 进程之间的 ipc
- apache-kafka - Kafka SSL 不将数据流式传输到 SSL Druid
- sql - 匹配 pgdump 中的多行 SQL 语句
- java - 尽管我添加了 return 语句,但我得到了我必须添加 return 语句的错误
- django - 如何在 Django 中创建一个不需要提供默认函数的 UUIDField,而是返回由数据库生成的 UUID?
- mongodb - 使用 mongDB 聚合函数中的条件进行计数