spring-kafka 相关问题

Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。

应用程序属性 spring.cloud.function.definition=测试 spring.kafka.bootstrap-servers=服务器名称-来自此处 spring.cloud.stream.kafka.binder. ProducerProperties.spring.json.add.type.headers=f...

apache-kafka spring-kafka spring-cloud-stream-binder-kafka spring-cloud-stream-binder

回答 1 投票 0

KafkaListener 在 Spring Boot 测试中未触发

我有一个 Spring Boot 测试来检查 kafka 消费者是否监听特定主题中的消息。使用@SpringBootTest时会触发kafka监听器。但我只是不想加载所有的类...

spring-boot apache-kafka spring-kafka spring-kafka-test testcontainers-junit5

回答 2 投票 0

KafkaJsonSchemaSerializer 将初始空字节 (00 00 00 00 0C 7B) 添加到记录值

使用以下 Spring-Boot 属性春天：简介：活动：“ssl” 卡夫卡：制片人：客户端 ID：${SPRING_KAFKA_PRODUCER_CLIENT_ID:kafka-生产者} 引导程序-

java apache-kafka spring-kafka confluent-schema-registry

回答 1 投票 0

java.lang.NoSuchFieldError：连接到 kafka 时出现 CLIENT_ENDPOINT 错误

我在连接到kafka时遇到错误..下面是一些错误行这是一个 Spring Boot 应用程序 2024-02-21T14:02:03.419Z 信息 1 --- [客户主服务] [ 主要] [ ] o.a.k.clients。

amazon-web-services spring-boot spring-mvc spring-kafka

回答 2 投票 0

如果kafka代理（localhost：9092）出现故障，我想发送邮件警报

如果kafka经纪人宕机，我使用下面的方法发送邮件警报，但如果kafka经纪人宕机，它就不起作用，我没有收到任何警报。如果 make ==> if(controllerId != null) 表示当

apache-kafka spring-kafka

回答 1 投票 0

具有两个输入主题的函数路由似乎破坏了 KafkaBinderMetrics

根据 https://stackoverflow.com/a/66871632/22992363，我正在配置一个功能路由器，它接受来自两个 Kafka 主题的输入。这是我的配置的精简副本：春天：云：

spring-kafka spring-cloud-stream

回答 1 投票 0

Kafka 流卡住分区

我们有一组 kafka 流/spring-boot/spring-kafka 应用程序，在过去几天发生了一个事件，我们注意到一个主题的单个分区有数千个我......

apache-kafka spring-kafka apache-kafka-streams

回答 1 投票 0

集成测试 KafkaListener - 确认侦听器已消费消息

大家好（希望是传奇人物加里·拉塞尔）我正在尝试为 Kafka Listener 编写一些集成测试，目的是确认我的 KafkaListener 能够使用

apache-kafka spring-kafka

回答 1 投票 0

使用Spring Boot @KafkaListener处理批量消息时无法获取自定义@Header

我有一个 Kafka 监听器，它接受一批消息。我需要从此侦听器获取自定义标头列表，但它给我一个错误，表明找不到标头。 @KafkaListener(id =

spring-boot spring-kafka

回答 1 投票 0

Kafka消费者ClassNotFoundException

（在开始提问之前，我的英语可能不足以清楚地描述所有内容。如果您不明白，请告诉我。）我正在尝试将数据对象从 A spring 项目（生产者）发送到 B ...

java apache-kafka spring-kafka

回答 1 投票 0

主题在 60000 毫秒后不存在于元数据中

用例场景：我试图确保万一生产者为了获取元数据而连接的代理（引导程序之一）不可用，然后在阻止它之后...

apache-kafka spring-kafka confluent-platform kafka-producer-api

回答 1 投票 0

带有 spring-kafka 的 Kafka 死信队列 (DLQ)

使用 spring-kafka 2.1.x 在 Spring Boot 2.0 应用程序中实现死信队列（DLQ）概念的最佳方法是什么，以满足 @KafkaListener 处理失败的所有消息...

java spring-boot apache-kafka spring-kafka dead-letter

回答 1 投票 0

Spring Kafka 错误：此错误处理程序无法直接处理“SerializationException”；请考虑配置“ErrorHandlingDeserializer”

生产者属性 spring.kafka. Producer.bootstrap-servers = 127.0.0.1:9092 spring.kafka. Producer.key-serializer = org.apache.kafka.common.serialization.StringSerializer spring.kafka.生产者.value-

java spring-boot apache-kafka spring-kafka

回答 2 投票 0

如何使用AOP（@Around注解）拦截kafka消息，并使用@KafkaListener注解进行监听

我正在将我的 spring-boot 应用程序从 spring-boot 2.7.x 升级到 3.2.x。在 spring-boot 2.7.x 中，我使用 @StreamListener 来监听来自 kafka 的消息，但在给予控制权之前...

spring-boot apache-kafka spring-kafka kafka-consumer-api spring-aop

回答 1 投票 0

如何检查Kafka连接是否正常？

我创建了一个使用 Kafka 的 Spring-Boot 应用程序。我的 application.properties 中有 Kafka 设置。 spring.kafka.bootstrap-servers = 本地主机：9092 spring.kafka.consumer.group-id = mygrp .... 在...

java spring-boot spring-kafka kafka-consumer-api

回答 2 投票 0

Spring Kafka RecoveryCallback 迁移

我正在使用 spring kafka 2.X，现在想迁移到 3.0 现在：我有一个侦听器容器工厂设置，仅用于重试功能，我在其中设置恢复，如下所示： @豆公开

spring-boot apache-kafka kafka-consumer-api spring-kafka

回答 1 投票 0

在 Kafka 生产者/消费者中用 CompletableFuture 替换 ListenableFuture

我正在迁移到 spring-kafka 3.1。我注意到的一件事是 ListenableFuture> future = kafkaTemplate.send(message); future.addCallback(新

java spring spring-boot apache-kafka spring-kafka

回答 1 投票 0

Spring Kafka：如何启动已停止的 MessageListenerContainer

我使用Spring Kafka。如果处理过程中发生错误，我想停止接收消息，然后在一段时间后恢复接收。我看到spring kafka有一个CommonContainerStoppingErrorHand...