手机版
热门标签
站点地图
我要投稿
广告合作
联系我们
搜 索
广告位招租
广告位招租
切换导航
首页
人工智能
编程教程
编程导航
编程百科
编程问答
编程博文
编程实例
硬件设备
网络运营
软件教程
移动数码
办公软件
操作系统
网络运维
技术频道
▸ 编程语言
▸ 前端开发
▸ 移动开发
▸ 开发工具
▸ 程序设计
▸ 行业应用
▸ CMS系统
▸ 服务器
▸ 数据库
公众号推荐
微信公众号搜
"智元新知"
关注
微信扫一扫可直接关注哦!
reactor-kafka
reactor-kafka专题提供reactor-kafka的最新资讯内容,帮你更好的了解reactor-kafka。
Kafka项目反应堆处理与背压异步
我正在使用Kafka反应堆。我使用了来自Kafka的一批消息,并将其异步存储在DB中,并且该操作返回了completa
作者:佚名 时间:2022-06-07
事务同步:如何使用 Reactor Kafka 和 R2DBC 创建 ChainedKafkaTransactionManager bean
我的 Spring Boot (WebFlux/R2DBC/Reactor Kafka) 应用程序中有以下使用者 <pre class="lang-kotlin prettyprint-override"><cod
作者:佚名 时间:2022-05-31
复制因子应该是在 Apache Kafka 中提供最多一次交付语义的一个吗?
据我所知,生产者不得重试任何失败的发送, 并且消费者必须在执行某些处理之前提交以提供最多一次
作者:佚名 时间:2022-05-29
ReactiveKafkaConsumerTemplate receiveAutoAck 的消息排序
我在问自己 spring-kafka 项目的 <code>ReactiveKafkaConsumerTemplate</code> 是否能保证消息的正确排序。我阅读了 rea
作者:佚名 时间:2022-05-28
Reactor Kafka 基于分区的消息消费
我想在我的反应式 kafka 消费者中精确控制消息消耗。我想从单个主题的每个分区同时读取特定数量的消
作者:佚名 时间:2022-05-25
Kafka 消费者中的手动偏移
我想编写一个 Kafka 消费者并在 Bigquery 中写入记录,我想在成功插入 Bigquery 时手动提交偏移量。我写了
作者:佚名 时间:2022-05-25
可以在没有代理的情况下创建 KafkaReceiver 吗?
我正在使用 <a href="https://projectreactor.io/" rel="nofollow noreferrer">reactor-kafka</a> 为 Kafka 消息创建反应式使用者
作者:佚名 时间:2022-05-18
Spring Boot Kafka - Kafka 指标在 /actuator/prometheus 中不可用
我想监控 Kafka 指标,但不幸的是,/actuator/prometheus 端点下不存在与 Kafka 相关的任何内容。我的设置中是
作者:佚名 时间:2022-05-17
单个服务范围内每个主题的不同 Kafka Producer 配置
我的问题是是否有可能以及如何在单个服务范围内为每个主题配置 Kafka Producer 设置?我在 <a href="https://d
作者:佚名 时间:2022-05-16
Reactor Flux - 仅在完成时从发布者发出
我有一些 Reactor Kafka 代码,它通过 <code>KafkaReceiver</code> 读入事件,并通过 1 个或多个 <code>KafkaSenders</code
作者:佚名 时间:2022-05-14
反应式 Kafka 接收器可以与非反应式 Elasticsearch 客户端一起使用吗?
下面是一个示例代码,它使用 reactor-kafka 并从一个主题(具有重试逻辑)读取数据,该主题具有通过非
作者:佚名 时间:2022-05-13
Kafka 反应器 - 如何禁用自动启动的 KAFKA 消费者?
下面是我的 KAFKA 消费者 <pre><code>@Bean("kafkaConfluentInboundReceiver") @ConditionalOnProperty(value = "com.dem
作者:佚名 时间:2022-05-12
如何在 Spring webflux 和 Kafka 中创建批量消费者
我需要轮询 kafka 并批量处理事件。在 Reactor kafka 中,由于它是一个流媒体 API,我将事件作为流获取。有
作者:佚名 时间:2022-05-10
RetryBackoffSpec 不适用于引发异常的 KafkaReceiver
我有一个用例,我想<strong>无限地继续接收</strong>来自 Kafka 的记录,并使用 <code>processRecord(String record)</c
作者:佚名 时间:2022-05-03
发送一批消息后我应该关闭KafkaSender吗?
应用程序是一个长期的消息接收器,应用程序接收上游消息并将消息转换为小消息,然后将这些小消息
作者:佚名 时间:2022-05-03
spring-cloud-stream Kafka Reactive 流分区分配如何与并发处理一起工作
例如,我配置一个主题有 2 个分区,但在我的应用程序中有 1 个实例,我使用 <code>Flux.parallel(10)</code> 来
作者:佚名 时间:2022-05-03
Reactor Kafka 中未创建订阅错误
消费者配置文件: 在这里,我将 StringDeserializers 用于键和值。并且订阅是针对一个主题进行的。 <pre>
作者:佚名 时间:2022-04-24
发送从反应堆 kafka 主题消耗的前 100 条消息后,如何有条件地发布额外的 SSE Web 流量事件
我正在使用具有 spring webflux SSE 流的 reactor-kafka 库从 kafka 主题中使用数据。当来自主题的所有消息都被
作者:佚名 时间:2022-04-22
Reactive kafka在生成消息时不断收到超时异常
尝试在 kafka 上生成消息时不断收到 <code>log:reactor.core.Exceptions$ErrorCallbackNotImplemented: org.apache.kafka.common.err
作者:佚名 时间:2022-04-21
JHipster 与 kafka 真实应用使用示例
在 <strong>JHipster</strong> 版本 <strong>6.6.0</strong> 中,Kafka 使用模型已从标准的 Producer/Consumer 类更改为 WebRes
作者:佚名 时间:2024-08-02
上一页
1
2
下一页
小编推荐
苹果市值2025年有望达4万亿美元
• 联想拯救者新一代Y700平板通过IMDA认证
• 最新AI生图模型Flux1.1刷屏!添加单反相
• 联发科天玑 9400 频率敲定,3.626GHz 最
• 苹果新品发布会来了!5款产品面临停产
• 佳能R5C Mark II配置曝光:双系统设计,
• AI应用的东风,奥特曼不想错过
• 为新品让路!苹果定制版Mac发货延期
热门标签
更多
python
JavaScript
java
HTML
PHP
reactjs
C#
Android
CSS
Node.js
sql
r
python-3.x
MysqL
jQuery
c++
pandas
Flutter
angular
IOS
django
linux
swift
typescript
路由器
JSON
路由器设置
无线路由器
h3c
华三
华三路由器设置
华三路由器
电脑软件教程
arrays
docker
软件图文教程
C
vue.js
laravel
spring-boot