Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。
Spring Kafka @DltHandler 注解方法在非阻塞重试实现中未正确接收标头
我正在尝试使用 Spring Kafka 实现非阻塞重试。根据此处的文档，我们可以设置一个处理程序方法来处理来自 DLT 主题的消息，在尝试完之后，...
Kafka 消息发送到单个主题而不是 n 重试主题和 dlt
我正在尝试使用DLT实现n重试主题，但所有消息都被推送到单个主题test-topic-retry-0，test-topic-retry-0中有3条重复记录，这些记录应该是...
GlobalKTable 作为带有 Kafka Streams Binder 的 QueryableStore
我正在使用 spring-boot-starter-parent 版本 3.1.2 和 spring-cloud-stream-binder-kafka-streams 版本 4.0.3 绝大多数在线示例都显示使用 @Input 注释创建 GlobalKTable...
我正在尝试寻找替代方案，因为 ChainedKafkaTransactionManager 显示@Deprecated
所以这是我的 ChainedKafkaTransactionManager 实现，因此它同时管理 kafkaTransactionManager 和 JpaTransactionManager，因为 ChainedKafkaTransactionManager 已被弃用，我想...
您好，我正在从 spring-boot 2 迁移到 3，并且与 spring-kafka 从 2.x 迁移到 spring-kafka 3.0.1 相关，发生了一些变化，我正在努力迁移一个类。 我正在尝试
将 JdbcMessageStore 添加到 Spring Kafka 聚合器
如何将 JdbcMessageStore 设置为 Aggregator，以便它使用 RDBMS 而不是内存中消息存储？ 目前AggregatorAnnotationPostProcessor直接设置new SimpleMessageStore(...
当前 DLT 配置未正确处理 DeserializationException
我正在使用 spring-kafka 3.0.4 和 AWS 基础设施。我想正确配置重试和 DLT，但在处理 DeserializationExceptions 时遇到一些问题。 我的一些 Kafka 配置包括...
我们可以在Spring Boot中使用多个kafka模板吗？
在我的 spring boot kafka 发布者应用程序中，我想提供对以 String(json) 或字节格式发布消息的支持，因为我想同时提供对 json 和 avro 的支持。但是
无法将 spring boot 与在 docker 容器中运行的 kafka 连接
我正在使用 docker-compose.yml 运行 kafka。我的 docker-compose.yml 的内容是： 版本：“3.8” 名称：“事件驱动系统” 服务： 卡夫卡： 容器名称：“卡夫卡&
多个消费者通过 spring-kafka 获得最新和最早的偏移选项
有一个消费者拥有最早的偏移选项和批处理，效果非常好。 现在需要添加另一个消费者，它应该在单一处理模式下工作并且始终可见......
根据https://docs.confluence.io/kafka/design/log_compaction.html#compaction-guarantees 任何关注日志头部的消费者都会看到写入的每条消息；这些
Spring Kafka MessageListenerContainer 恢复/暂停# spring-kafka
由于本机 KafkaConsumer 不是线程安全的，因此不鼓励从不同线程而不是 kafka-consumer 处理线程调用暂停和恢复方法。 但由于 spring-kafka 提供了 ano...
使用回调处理程序并通过外部系统进行身份验证时，Kafka 服务器中的许多身份验证可见
我们使用 Kafka callback.handler KIP-86 将身份验证委托给外部系统（Keycloak）。 Listener.name.sasl_plaintext.plain.sasl.server.callback.handler.class=com.xxxxxx 我们的java
一个 kafka 代理、一个测试上下文中的所有嵌入式 kafka 测试
我有带有一些嵌入式kafka测试@EmbeddedKafka的Spring应用程序。 对于每个测试，我都需要一个单独的主题。 @ExtendWith(SpringExtension::class) @SpringBootTest( 类= [ 申请...
ProducerServiceIntegrationTest 的集成测试给出错误：org.springframework.kafka.KafkaException：发送失败；嵌套异常是 org.apache.kafka.common.errors.TimeoutException：主题
我有一个场景，Spring Boot 项目中有一对主题（一个快照和一个增量主题），应该按照以下规则使用它们： Delta 主题是听...
我有一个将添加到数据库的 Spring 应用程序，从另一方面，我想监视数据库是否更改，因此我对新更改进行一些统计并将它们发送到另一个数据库...
带有 Kafka 的 Spring Boot 3 确认回调不起作用
我正在使用 spring-kafka 测试 Spring Boot 3。我希望在处理发送的消息时（在消费者中执行确认时）收到通知（类似于回调）。电流...
使用Confluence平台测试基于kafka的后端应用程序？
基于pub-sub模型的后端应用程序的功能测试用例是如何编写的？ 请问有什么例子吗？ 我尝试使用 Confluence 平台来测试 kafka 生产者和消费者，但我......
任何人都可以告诉我们使用 Confluence 平台测试基于 kafka 的后端应用程序的分步过程吗？
基于pub-sub模型的后端应用程序的功能测试用例是如何编写的？ 请问有什么例子吗？ 我尝试使用 Confluence 平台来测试 kafka 生产者和消费者，但我......