回答情况：
提问时间：
问题标签：
我必须使用来自reactive-kafka模块的代码：val kafka = new ReactiveKafka()
val kafkaIdpsMsgs: Publisher
浏览 6提问于2016-08-23得票数 0
我一直在尝试使用reactive-kafka，我在条件处理方面遇到了一个问题，我没有找到一个令人满意的答案。
浏览 13修改于2018-02-16得票数 0
回答已采纳
我查看了以下文档：和我看到了以下代码片段：implicit val materializer = ActorMaterializer()
val publisher: Publisher[StringConsumerRecord] = kafka.consume(ConsumerProperties( top
浏览 7提问于2016-08-28得票数 0
回答已采纳
我找不到任何支持reactive-Kafka的勇敢仪表库。
不支持Reactive-Kafka。有没有一个库或repo可以帮助我在java中为reactive-Kafka进行Zipkin跟踪？
浏览 1修改于2019-07-24得票数 1
我们已经发现reactive-kafka使用它自己的dispatcher (akka.kafka.default- dispatcher )，但是，如果我们使用默认的akka dispatcher，一切都会更快(reactive-kafka dispatcher ~300 messages/s，default dispatcher ~1300 messages/s )
我想知道使用默认调度程序是否安全。
浏览 2提问于2016-06-11得票数 3
我使用spring-kafka作为reactive-kafka的包装器。
浏览 38修改于2021-10-02得票数 3
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号