Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。
@KafkaListener @SpringBoot-3 中的Payload 验证
我在 @KafkaListener 中使用了记录的有效负载验证方法，它在 SpringBoot-2.7 和 spring-kafka-2.8 中工作得非常好。但是升级到SpringBoot-3.2和spring-kafka-3后....
使用架构注册表生成 Kafka 事件时，运行时期间 io.confluence.kafka.serializers.context.NullContextNameStrategy 值无效
每次在生产环境中生成 Kafka 事件时，我都会在运行时收到以下错误消息。请注意，相同的代码在我的本地设置中可以正常工作，没有任何问题，并且全部
spring-kafka 和 spring-cloud-starter-stream-kafka 中定义的属性有什么关系？
我继承了一个应用程序，使用 spring-kafka (@KafkaListener) 和 spring-cloud-starter-stream-kafka 的功能。 有关 spring-cloud-starter-stream-kafka 属性的文档...
我正在使用一个 Spring Boot Java 项目，其中我提到了一个消费者组，并且刚刚创建了一个消费者实例。这意味着如果我从这个消费者那里轮询数据，它应该默认重新...
spring-kafka：RetryTopicConfiguration 具有用于重试和死信主题的自定义名称
我提供了一个用于重试主题配置的bean： @豆 公共 RetryTopicConfiguration kafkaRetryTopicConfig(...) { 返回RetryTopicConfigurationBuilder .newInstance() .fixedBackOff(......
使用EmbeddedKafka在Spring Boot测试中测试Spring Kafka Listener
我正在尝试使用 @EmbeddedKafka 在 Spring Boot 测试中测试 Spring Kafka 侦听器。但是，我不断遇到以下异常： 没有交易正在进行中；可能的解决方案：运行
Spring Boot Kafka Listener并发数小于分区数
例如，Kafka 消息的消费情况如何？ 每个主题 12 个分区 2个微服务正在运行 每个微服务都有一个并发 Kafka 消费者，具有以下功能
有问题请教。将使用 spring kafka 监听器 @KafkaLister 无限期地重试批处理。 我尝试的方法是让侦听器容器具有立即_手动确认，然后不
我们正在尝试在java spring项目中实现Kafka Acknowledgment。如果没有确认，我们可以成功接收并读取消息，但是当我们在方法中添加确认时，我们会...
使用 Spring-Kafka 和 Confluence 模式注册表将带有 JSON 模式的记录发送到 Kafka
我在互联网上找不到任何有关如何使用 spring kafka 将带有 json 模式的记录发送到 kafka 的信息。我怎样才能做到这一点？
批处理模式下的 Spring Cloud Stream Kafka 消费者不会重试
我在Spring Boot应用程序中使用Spring Cloud Stream（版本4.0.3）和Kafka Binder来批量消费来自Kafka Topic的消息。当抛出异常时，整个批次都会被处理...
每当我的服务重新启动时，如何在 Spring Boot 应用程序的启动中使用偏移量 0 处的 kafka 消息
每当我的服务重新启动时，我想在 Spring Boot 应用程序的启动中消耗来自 0 偏移量的所有 kafka 消息。下面是我的 kafka 配置，但它不起作用。 @豆 公开
如何在springboot服务完全运行之前读取Kafka主题中的所有消息
我有一个要求，我的 springboot 服务正在从名为 k1、k2、k3、k4 和 k5 的 Kafka 主题读取数据。 spring boot 服务有它自己的内部缓存，它通过消耗而被填充......
单个Spring的KafkaConsumer监听器可以监听多个topic吗？
有人知道单个监听器是否可以监听多个主题，如下所示？我知道只有“topic1”有效，如果我想添加其他主题怎么办？您能举例说明下面两者吗？谢谢...
嗨，所以我有一个非常基本的 Spring Boot 应用程序，该应用程序发布到 kafka 主题 我对容器进行了集成测试，设置如下： 受保护的静态最终 KafkaContainer KAFKA_CONTAINE...
我第一次尝试卡夫卡流，我得到了一种我不太理解的行为。我有一个制作人以以下格式发送有关输入主题的消息： {“fooId”：“...
Kafka 映射类型 - 由于找不到类定义，消费者在应用程序运行期间失败
我知道类似的问题已经被问过，我已经尝试了所有这些，但我无法解决它。 请在下面找到尝试过的参考文献的链接： 如何配置 Kafka 类型映射...
如何在ProducerRecord中设置kafka消息key
目前我正在使用 org.springframework.kafka.core.KafkaTemplate 来发布带有标题的主题的 avro 消息。 @覆盖 公共 ListenableFuture> 发送（消息<...
如何在ConcurrentKafkaListenerContainerFactory上设置AbstractConsumerSeekAware？
我正在尝试在 ConcurrentKafkaListenerContainerFactory 上设置通用 MessageListener，如下所示 @成分 @Slf4j 公共类 GossiperMessageListener 扩展 AbstractConsumerSeekAware 实现...
我收到错误：org.apache.kafka.common.errors.InvalidReplicationFactorException：复制因子：3 大于可用代理：1
我在 Spring Boot 中通过 Kafka 应用程序运行时收到此错误。我想通过运行我的应用程序来创建主题。 这是我的配置类： @配置 公共类 KafkaConfig {...