回答情况：
提问时间：
问题标签：
我正在尝试reactor-kafka消费消息。其他一切都很好，但我想为失败的消息添加一个retry(2)。默认情况下，spring-kafka已经重试了3次失败的记录，我想用reactor-kafka来实现同样的效果。 我使用spring-kafka作为reactive-kafka的包装器。
浏览 38修改于2021-10-02得票数 3
回答已采纳
我们使用reactor-kafka，所有的处理都需要反应式的。如何在仍然使用reactor-kafka的情况下实现“出现N个错误后提交”行为
浏览 23提问于2020-04-09得票数 2
然而，reactor-kafka documentation提到KafkaReceiver不是线程安全的，因为底层KafkaConsumer不能被多个线程并发访问。 我正在寻找从一个主题阅读的建议。
浏览 32修改于2021-07-28得票数 0
回答已采纳
我正在使用reactor-kafka库和spring webflux SSE流消费来自kafka主题的数据。
浏览 7修改于2021-06-29得票数 1
我正在尝试开发一个Spring应用程序，使用库reactor-kafka对从Kafka主题读取的一些消息做出反应。
我有一个构建KafkaReceiver的配置类。
浏览 5修改于2019-03-19得票数 8
回答已采纳
我阅读了reactor-kafka项目的文档，它指出消息应该使用concatMap操作符，但ReactiveKafkaConsumerTemplate至少在这里使用receiveAutoAck方法的情况下使用
浏览 37提问于2021-01-26得票数 0
回答已采纳
")compile 'io.projectreactor.kafka:reactor-kafka
浏览 7修改于2019-06-12得票数 0
回答已采纳
我们的应用程序使用springBootVersion = 2.0.4.RELEASE和compile('io.projectreactor.kafka:reactor-kafka:1.0.1.RELEASE
浏览 154提问于2019-02-13得票数 1
回答已采纳
dependency> <groupId>io.projectreactor.kafka</groupId> <groupId>io.projectreactor.kafka</groupId>
<artifactId>reactor-kafka
浏览 9修改于2020-01-02得票数 3
回答已采纳
在reactor-kafka中，它使每一批Record都是一个Flux<Record>，它如何实现像记录级上下文这样的东西？ 谢谢。
浏览 28修改于2020-08-15得票数 1
回答已采纳
) [na:1.8.0_261]<dependency> <artifactId>reactor-kafka
浏览 51提问于2021-06-11得票数 0
回答已采纳
artifactId><dependency> <artifactId>reactor-kafka
浏览 70修改于2018-06-08得票数 3
回答已采纳
语言：Kotlin
反应堆卡夫卡库：io.projectreactor.kafka:reactor-kafka:1.2.2.RELEASE
浏览 12修改于2020-08-05得票数 1
-- https://mvnrepository.com/artifact/io.projectreactor.kafka/reactor-kafka --> <artifactId>reactor-kafka</artifactId>
<version
浏览 16提问于2019-12-20得票数 0
我正在尝试使用reactor-Kafka - https://projectreactor.io/docs/kafka/1.3.5-SNAPSHOT/reference/index.html#_introduction
浏览 14修改于2021-08-04得票数 0
包版本
1.3.61Spring Kotlin Boot - 2.2.3.RELEASEio.projectreactor.kafka:reactor-kafka:1.2.2.RELEASEorg.springframework.kafka
浏览 3提问于2020-01-26得票数 1
回答已采纳
使用的版本如下org.apache.kafka:kafka-streams:2.8.0
io.projectreactor.kafka:reactor-kafka
浏览 1提问于2021-08-04得票数 0
回答已采纳
spring-boot-starter-webflux', version: '2.2.5.RELEASE'
implementation group: 'io.projectreactor.kafka', name: 'reactor-kafka
浏览 19修改于2020-04-19得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号