Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。
在 https://docs.spring.io/spring-kafka/reference/html/#overview-2 上说明了以下内容： 从版本 2.5.8 开始，您现在可以在生产者工厂上配置 maxAge 属性。这是你...
我想在处理/反序列化失败时重试消费消息有限次。重试次数耗尽后，我想记录一条消息，提交偏移量并移动
Spring boot spring.kafka.bootstrap-servers 没有被消费者配置拾取
我正在尝试使用将 spring boot 项目连接到 kafka 。 在我的 application.properties 文件中，我有以下配置： spring.kafka. Producer.key-serializer = org.apache.kafka.common.serialization
kafkaconsumerfactory 与 kafkalistenercontainerfactory
Spring Kafka 中消费者和容器之间的关系/区别是什么？ 我问这个问题是因为Spring提供了kafkaconsumerfactory和kafkalistenercontainerfactory，而我
你能解释一下我应该在下面的代码中哪里得到丢失的属性吗？ （smth 应该在 lsat 行中） KafkaProperties prop = new KafkaProperties(); KafkaProperties.Producer 生产者 = prop.
使用 org.springframework.messaging.Message 和 Protobuf 对象作为 kafka 消息时出现 ClassCast 错误
我使用 spring-kafka 和生产者属性如下 键序列化器：org.apache.kafka.common.serialization.StringSerializer 值序列化器：io.confluence.kafka.serializers.protobuf。
实例内的 KafkaListener 分区映射并发度 > 1
我有一个简单的kafka监听器注释方法 和 spring.kafka.listener.concurrency = 5 我的主题有 100 个分区，并且有 5 个应用程序实例正在运行。 主题有分区...
我基本上有一个带有 Spring Boot 应用程序多个任务的系统，使用以相同消费者组 id 运行的 Kafka 消费者类。它们都与同一主题相关。我没有
Spring kafka无限重试，无需retryabletopic注解
我们使用 spring Kafka 3.x 并使用 DefaultErrorHandler。 在此处理程序中，我们检查异常是否可重试，然后重试直到 Integer.maxValue，否则将消息放入 DLT 中。 整个想法是...
Spring控制器和kafka tempalte线程模型——kafkatemplate可以使用多线程发送消息吗？
以下是使用 Spring 控制器向 Kafka 发出 Web 请求的示例： @RestController 类 KafkaProducerController(val kafkaTemplate: KafkaTemplate) { @PutMapping...
按顺序消费消息。主题 1 的消息应该在主题 2 的消费之前被消费
我有一个场景，首先使用主题 1 中的消息，然后使用主题 1 中的所有消息，然后使用主题 2 消息。正如您在上面的评论中提到的，我使用了 ContainerGroupSequencer。 作为
我的应用程序使用来自 2 个不同集群的相同主题名称 唯一出现的指标标签是“spring.id”， 需要添加更多标签 - 例如集群名称 试图实现这个 哈...
RecordInterceptor Spring Framework Kafka Listener 中的多个拦截方法
我有一个类，它实现了RecordInterceptor。从 Spring-Kafka 阅读文档，有一个名为拦截的方法，它有 2 个参数：Record 和 Consumer。然而对于...
我使用的是spring-kafka 2.9.12，我想在消息发送后的一段时间内消费来自主题的消息。为此，我找到了两种方法。 第一种方法如下，...
我们有许多用于多个任务的微服务，其中大多数都有一些常见的功能，如日志配置、指标配置和kafka配置等。 我们计划有一个合作...
我有 KafkaListener 课程： @Slf4j @成分 @RequiredArgsConstructor 公共类文档监听器{ @KafkaListener(topics = "${spring.kafka.consumer.from-hotfolder-transferer.top...
如何与Spring Cloud Streams供应商发送消息/数据？
当特定表记录中有插入时，我尝试在kafka上发送消息。 我认为申请的这一部分将被视为供应商/生产商。 我有以下c...
我怎样才能获得具有exactly_once_v2保证的Kafka Streams应用程序以与AWS MSK一起使用
当我配置了启用processing.guarantee=exactly_once_v2 的Spring Boot Kafka Streams 应用程序时，我在运行它时遇到问题。当我启动我的应用程序时，它最终崩溃了（我所有的...
在另一个 KafkaListner（压缩主题 2）完成读取消息后启动 KafkaListner（主题 1）
我有一个场景，我必须从头开始阅读压缩主题（主题2）中的所有消息。我必须将所有这些消息保存在内存中，它将充当查找/缓存。 我还有另一件上衣...
当切入点位于界面中时，Spring Aspect 对 KafkaListener 函数不起作用？
我在spring kafka的GenericMessageListener上添加了一个切入点， 我正在使用@KafkaListener，并且该方面不起作用。如果我将切入点更改为 KafkaListener 的注释，它就可以工作...