spring-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) 。两者都已被弃用并从...

AKS 中部署的微服务无法连接到 AKS 中部署的 kafka

我正在将 Spring 微服务项目部署到 AKS，其余服务工作正常，但是当我部署使用 Kafka 的服务时，在我使用 helm 单独部署 Kafka 后， 我重复了

引起：com.fasterxml.jackson.core.JsonParseException：无法识别的标记“ÿ”：正在等待（JSON字符串，数字，数组，对象或标记“null”，

我正在使用 Spring Boot Apache Kafka 示例并出现以下错误。 原因：com.fasterxml.jackson.core.JsonParseException：无法识别的标记“ÿ”：正在等待（JSON字符串，数字，数组，Obj...

原因：org.messaging.handler.annotation.support.MethodArgumentNotValidException：无法解析 public void 中索引 1 处的方法参数

我正在开发 Kafka Consumer App，在手动尝试确认和确认时出现以下错误。可能是什么原因导致了这个问题？ 错误详情： org.springframework.kafka.listener.

在 Spring Kafka 中为批量监听器实现自定义错误处理程序

我将向我的容器工厂添加自定义错误处理程序 这是我的要求： 我有一个批处理侦听器，即使某个特定记录由于

批处理时验证Kafka消息

我正在使用 spring kafka 监听器批量处理消息，我希望在处理之前对它们进行验证。这是我配置 kafka 监听器的方式 @KafkaListener(id = "listener.id&qu...

从配置kafkalistener中读取

我有一个 Spring Boot 应用程序，其侦听器如下： @KafkaListener(id = "演示", 主题 = "演示", containerFactory =“重试KafkaListenerContainerFactory”） 公共空间

使用 ErrorHandlingDeserializer 自定义日志和增量指标

我正在使用最新版本的 Spring Kakfa，3.1.3，似乎异常处理方面最近的一些变化让我感到困惑。 当毒丸进来时，我只想以特定方式登录，然后

KafkaListener 反序列化到 Avro POJO 类时出现“Caused by: org.springframework.messaging.converter.MessageConversionException”

我正在使用 Spring Boot 构建一个 Kafka 监听器/消费者，它消耗来自主题的 Avro 数据。 这是一些属性 spring.kafka.properties.spec.avro.reader=true spring.kafka.consumer.

嵌入式Kafka 测试因 java.lang.NoSuchFieldError: id 失败

将组件从 Spring Boot 2.7.18 升级到 Spring Boot 3.2.2 时，我们看到所有 spring-kafka EmbeddedKafka 测试都失败，并出现以下 Spring 初始化错误： java.lang.NoSuchField...

Kafka SSL 连接被拒绝：没有更多信息

我正在努力在 Kafka 服务器和 Spring（启动）Kafka 客户端之间设置 Kafka SSL。 我有一个使用 SSL 的工作 Kafka 服务器，如下所示：http://kafka.apache.org/documentation/#securi...

当自动提交设置为 false 时，Kafka 监听器开始消费消息时如何重新传递消息

假设我启动消费者时将自动提交设置为 false 并且消费者开始监听消息。 我的监听器处理了 50 条消息，轮询总数为 100 条，然后只处理了 50 条......