spring-kafka 相关问题

如何验证spring kafka生产者是否成功发送消息？

我正在尝试测试 spring kafka(2.2.5.RELEASE)，当生产者使用 kafkatemplate 发送消息时，我想知道该消息是否发送成功。基于此我想更新...

Kafka Consumer 测试适用于 SpringBootTest，但不适用于 ContextConfiguration

根据我对基于文档的@SpringBootTest配置的理解，如果指定了classes参数，则相当于具有相同参数的@ContextConfiguration： 比较...

spring kafka 生产者发起的事务无法按照 spring 文档中的描述工作？

我正在使用 spring boot 3.3 和 spring kafka 3.2，想要测试 spring 文档中描述的事务同步部分：https://docs.spring.io/spring-kafka/reference/kafka/transact...

避免 Spring Kafka 设置的 __TypeId__ 和 spring_json_header_types 魔法标头

我正在尝试配置 Spring Kafka，以便通过 KafkaTemplate 发送的事件不包含神奇的 __TypeId__ 标头。 根据我在文档和在线阅读的内容，JsonSerializer。

通过 Spring-Kafka 列出 Kafka 主题

我们希望通过 spring-kafka 列出所有 Kafka 主题，以获得类似于 kafka 命令的结果： bin/kafka-topics.sh --list --zookeeper 本地主机:2181 当运行

Spring Kafka 消息转换在 Spring Boot 3.3 上失败

我们刚刚将 Spring Boot 项目从 3.2.4 更新到 3.3.0，我们遇到了一些有关很棒的 lib spring-kafka 的问题。我们的 kafka 监听器是 ack-mode=record 并期望作为参数 a

spring kafka 3.2 将事务管理器设置到侦听器容器中的非弃用方法是什么？

我正在使用 sprking kafka 并注意到在 3.2 版本中 setTransactionManager 已在 ContainerProperties 中被弃用： @豆 公共并发KafkaListenerContainerFactory

Spring Boot with Kafka - 使用 DLQ 时不记录反序列化异常

使用SpringBoot 3.0.6 我正在编写一个示例“SpringBoot Kafka”毒丸示例，以确保消息被放入 DLT 中。我有两种情况： 消息反序列化失败 梅萨...

Spring Kafka RequestReply ListenableFuture Threads Park问题

应用概述 我们通过 Apache Kafka Topic 集成了 2 个微服务。 微服务 1 [MS1] 使用 Spring Kafka 请求-回复模板通过 Kafka TOpic 向微服务 2 [MS2] 发送消息...

@SpringBootTest 中未触发带有containerFactory的@KafkaListener

我正在尝试使用 @SpringBootTest 和 Testcontainers 作为底层基础设施为我的 Kafka 消费者编写集成测试。我的设置如下所示： @成分 @ConditionalOnPro...

spring kafka为clientId添加-n后缀，如何去掉

对Spring kafka了解有限。我正面临这个问题。 如日志中所示，spring 为客户端 ID 添加 -1 （或 -0）。这造成了一个问题，因为 kafka 基础设施的名称是......

使用 Spring Boot 3.2.6 和 Spring Cloud 2023.0.2 的 Kafka Producer 配置中存在 `bootstrap.servers` 问题

升级到较新版本的 Spring Boot 和 Spring Cloud 依赖项后，我在 Spring Boot 应用程序中遇到 Kafka 生产者配置问题。 环境 Spring Boot：...

kafka：取消了正在进行的 METADATA 请求，由于请求超时而与节点断开连接

我有 spring-kafka:3.0.3、SSL，我能够将我的消费者连接到引导服务器并成功消费消息。 但除此之外我看到这样的日志消息 飞行途中取消

ec2 信任库位于哪里？

ec2 trustore 位于哪里？ 我们需要 truststore.jks 和密码才能从 Spring Boot kafka 应用程序连接到 AWS MSK 集群。 我指的是带有 jks 的 SSL 密钥库和信任库文件夹

Spring-Boot-Kafka：如何在java中设置主题配置

我正在将 Spring-Boot 与 Kafka 结合使用。 pom.xml 的部分 ... org.springframework.boot spring-boot-starter-parent...

此错误处理程序无法处理 'org.apache.kafka.common.KafkaException's;没有记录信息

将 Java 从 Spring 2.x 迁移到 3.x 时，我也将 spring-kafka 依赖项升级到版本 3.0.13。现在已弃用我使用的旧错误处理程序，即 SeekToCurrentBatchErrorH...

消费者中的@KafkaHandler不会将主题消息作为对象类消费，而仅作为字符串消费

我有一个简单的 Java Spring Boot 应用程序，它应该将来自 Kafka 的主题消息作为对象类使用，但它只能作为字符串调用。仅调用了handleDefault..为什么？ @

Kafka - 重置分区偏移量不起作用

我有一个主题“oranges”，有 10 个分区，1 个消费者组内有 2 个消费者。我正在使用 Spring Kafka。 由于某些原因，我需要时不时地重新读取数据，我需要重置

如果消息处理失败，Kafka-reactor 会再次读取相同的 kafka 消息

从 kafka 读取时，我希望保证在处理来自 kafka 的下一条消息之前，我的 kafka 消息已成功存储在数据库中。我使用java-spring kafka-reactor。这是一个简单的

替代Kafka 3.6.2中的@EnableBinding和@StreamListener

我一直在致力于从 Spring 2.X 到 3.X 的迁移，我的旧代码在消费者中使用了 @EnableBinding(Sink::class) 和 @StreamListener(Sink.INPUT) 。两者都已被弃用并从...