Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。
Spring Boot 3 + Kafka 未在与 SB 2.7 相同的轮询超时中加入/获取记录
所以我已将我的应用程序更新到 Spring Boot 3，特别是 3.1.6，但这个问题在我尝试过的所有 3.x 版本上都存在。 基本上旧的轮询时间不足以接收记录
Spring云流kafka流binder——函数式编程模型中的@Transactional注解
如果在事件处理过程中发生异常，我无法执行数据库事务回滚。我正在使用 Spring Cloud Stream 和 Kafka Stream Binder - 以及函数式编程模型......
我正在使用 spring kafka 并面临一些错误 向节点 1001 发送获取请求（sessionId=INVALID，epoch=INITIAL）时出错：org.apache.kafka.common.errors.DisconnectException。 我的消费者生产者...
我们正在使用测微计为 Spring Boot 应用程序构建一个监控系统。 收集的指标通过 micrometer-registry-elastic 发布到 Elasticsearch 实例。 一切都是f...
如果 ResolvableType 已在标头中，则会发生 InvalidDefinitionException
我们在项目中使用了spring集成和spring kafka。 从 Spring-boot 3.1.7 更新到 3.2.1 后，我们在消息序列化期间遇到异常。 给定流程： @豆 综合...
我想从App1发送一个对象到App2更新它然后将其返回给App1。 目前该对象没有得到更新，App1 打印它最初在回调函数中发送的对象。我需要应用程序...
如何使用Spring kafka事务和Spring data jpa？
如何使用Spring kafka事务和Spring data jpa事务？我的应用程序中的 jpa 事务管理器消失并抛出此错误：组件需要一个名为“
Spring Boot 3.1.X及以上版本的Kafka客户端连接问题
我最近将我的一项 Spring Boot 服务升级到 3.1.x，升级后我遇到了 kafka 问题。它似乎无法连接并不断向我提供以下日志。 2024-01-03T06:18...
在我的 SpringBoot Java 项目中，我使用的是 kafka，特别是 ReactiveKafka。我正在更新依赖项，特别是这些依赖项： springboot 2.6.6 -> 3.1.5 弹簧卡夫卡 2.8.0 -> 3.0.11 反应堆-
不断发展的 Avro 架构（其中记录名称发生更改）和使用别名不起作用
所以我有一个 avro 模式，我想发展它并使用 topicRecordName 策略。我正在使用融合模式注册表。我想让它向后兼容，并且有必要更改
我想从Kafka获取数据，此方法成功获取记录但无法传递给变量。这是我的代码 公共无效 subscribeFromKafka() 抛出异常 { 列表结果=新
Kafka Java Consumer Client 是单线程的吗
我们正在开始使用 Kafka， 在阅读本文时 - https://docs.confluence.io/kafka-clients/java/current/overview.html - 它似乎暗示客户端是单线程的。 * 由于这个...
假设最初我们有一个包含 3 个分区的主题和一个包含 3 个消费者的消费者组，从该主题进行消费。如果我们在消费者组中再添加一个消费者，分区会重新平衡吗
我有一个 Spring Boot Kafka 流应用程序。 升级到SB3后，spring.cloud.function.definition不再被识别。 我启用了调试日志并提供了帮助。 我在
我目前正在使用 spring kafka 实现 kafka 监听器。 现在我有点困惑，因为我的侦听器有时无法分配到分区，因此无法从其中之一接收任何消息
我使用 spring-boot (2.2.4)、spring-kafka (2.3.5)、Gradle 和 Kotlin。 我想使用标头来映射类型，但我不明白该怎么做...... 我查看 spring-kafka 参考并编写下一个代码...
KStreams 在 Spring Cloud Stream 中运行速度非常慢
我已经在Spring boot中使用SpringCloudStreams实现了KStreams。 我已准备好从具有 20 个分区的主题写入具有相同分区数的主题。我有 2 个 Pod 正在运行。 平均...
我有使用 spring-kafka 和 kafka-streams 的 Java Spring-boot 应用程序。 我正在尝试使用以下命令构建 GraalVM 本机映像 mvn -Pnative spring-boot:build-image 构建成功，但是当我尝试时...
StreamsBuilderFactoryBeanCustomizer 未自定义 StreamsBuilderFactoryBean
我有带有 Kafka 流的 springboot 应用程序，其中我肯定主要的 bean 如下。 @豆 公共 StreamsBuilderFactoryBeanCustomizer StreamsBuilderFactoryBeanCustomizer（CustomStateListener
有没有办法在尝试消费来自 Quarkus 的消息时管理并发消费者的并发性？ 我正在寻找具有并发性的批处理，以便在短时间内处理多条消息...