Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。
如何实现ReplyingKafkaTemplate而不使用@KafkaListener和@SendTo发送响应到回复主题
美好的一天。 我正在尝试使用 ReplyingKafkaTemplate 实现同步请求回复消息流。作为个人 POC，它运行良好。但我的应用程序已经实现了 kafka 来消费
未调用自定义 DeadLetterPublishingRecoverer
我们正在从 Spring Boot 2 / spring-kafka 2.8.4 升级到 Spring Boot 3 / spring-kafka 3.1.2 并且必须从 SeekToCurrentErrorHandler 过渡到 CommonErrorHandler。我们最初的尝试
也许你可以帮助我并告诉我在设置 EmbeddedKafka 时错过了什么 所以我使用EmbeddedKafka在项目中测试我的@KafkaListener： 我创建了简单的测试 @SpringBootTest @EmbeddedKafka(/*
引起：org.apache.common.config.ConfigException：bootstrap.server 中没有给出可解析的引导 URL 当我在配置中添加此内容时： @配置 类主题配置{ 公关...
我是 Kafka 新手，我正在尝试使用命令行创建一个主题，但出现以下错误： C:\kafka in\windows>kafka-topics.bat --create --topictutorialspedia --boot...
原因：java.lang.IllegalStateException：标头中没有类型信息且未提供默认类型
在我的项目中，我们使用 Spring XML 配置（目前没有范围使用 Spring Boot），我希望通过良好的异常处理和重试机制来实现 Kafka 消费者。 另外，也想
在Spring Boot中使用EmbeddedKafka测试Kafka消费者@KafkaListener
我想测试我的kafka消费者，但是@EmbddedKafka存在问题。 @Slf4j @成分 @RequiredArgsConstructor 公共类 KafkaEventConsumer { 私有最终 CustomInterface customInt...
我正在开发一个Springboot应用程序，它使用Spring-kafka来实现Kafka Producer以将消息发送到Kafka集群。 在第一次迭代中，我们在 AKS 中部署了 Spring 应用程序
Kafka Producer - Spring Boot 应用程序 - 无法生成消息
我也在学习Spring Boot和Kafka。我进行了一些探索并配置了一个示例生产者应用程序，如下所示。但是我无法发布这些消息。 如果我能得到那就太好了
DefaultErrorHandler 不可配置如果 @RetryableTopic 用于重试和 DLT 处理程序
春季启动版本：2.7.6 春季卡夫卡版本：2.8.11 问题： 我试图处理代码中的反序列化问题。为了在代码中处理此类问题，我通过扩展创建了自己的类
KafkaTemplate.send() 既不返回也不抛出异常
我正在使用 SpringKafka（Springboot 版本 3.1.7）将消息发布到 Azure EventHub 命名空间。生产者应用程序也部署在 Azure 中。直到上周一切都运转良好，但最后
如何在Spring XML + Kafka App中进行错误处理？我正在使用 JSON 来生成和消费消息，但是当消费者获取垃圾数据时，它会运行无限循环。 这是我用过的 spring.xml ...
我想扩展这里面临的进一步问题：设置构造函数时的 org.springframework.kafka.support.serializer.ErrorHandlingDeserializ' of type serializer.ErrorHandlingDeserializer]
在java项目中使用kafka进行更新和插入操作是不是一个好主意？
在java项目中使用kafka进行更新和插入操作是一个好主意吗？我们正在将遗留批处理项目从 Perl 迁移到 Spring Boot 微服务，并且我们计划使用 kafka 作为 DB
每个任务的 KafkaProducer 或单例 KafkaProducer
我有几个并行运行的任务（ExecutorService 和 Runnable 任务）。对所有这些都使用一个 KafkaProducer 实例（Spring singleton bean）是一个好的选择吗？在这种情况下，如何
通过参考：How to handle the exception at Consumer in Spring XMl App?，我试图在 xml bean 中转换 Java bean 依赖关系并面临以下错误。 有人可以解释一下...
我在卡夫卡消费者端遇到了下面的异常。令人惊讶的是，这个问题与旧版本的代码不一致（具有完全相同的配置，但有一些新的不相关...
Spring XMl App中consumer端如何处理异常？
如何在Spring XML + Kafka App中进行错误处理？我正在使用 JSON 来生成和消费消息，但是当消费者获取垃圾数据时，它会运行无限循环。 已在此处上传代码：https://
Spring boot kafka - 如何告诉 JsonDeserializer 忽略类型标头？
Spring 的 Kafka 生产者将类型标头嵌入到消息中，该消息指定消费者应将消息反序列化到哪个类。当生产者不使用 Spring Kafka 时，这是一个问题...
我想将这段Java代码迁移到Spring Boot 3： 公共无效发送（字符串主题，K键，V消息，BiConsumer，Throwable>回调）{ 完整的未来 我想将此 Java 代码迁移到 Spring Boot 3： public void send(String topic, K key, V message, BiConsumer<SendResult<K, V>, Throwable> callback) { CompletableFuture<SendResult<K, V>> future = kafkaTemplate.send(topic, key, message); if (Objects.nonNull(callback)) { future.whenComplete(callback); } } ...... // call kafka method kafkaProducer().send("topic", "key", "messge", listenableFutureCallback("12345")); ...... private ListenableFutureCallback listenableFutureCallback(String userId) { return new ListenableFutureCallback() { @Override public void onFailure(Throwable ex) { ....... } @Override public void onSuccess(Object result) { ........ } }; } 我在这一行遇到错误：listenableFutureCallback("12345") Required type: BiConsumer <org.springframework.kafka.support.SendResult<java.lang.String,java.lang.String>, java.lang.Throwable> Provided: ListenableFutureCallback 你知道我应该如何迁移/替换 ListenableFutureCallback 以便从 BiConsumer Java 方法返回 listenableFutureCallback 吗？ 这似乎是 BiConsumer 导入的问题。您应该使用“java.util.function.BiConsumer”中的 BiConsumer，而不是“org.apache.kafka.commonKafkaFuture.BiConsumer”。 PS：据我了解，ListenableFutureCallback 在 Spring 6.0 中已被弃用。请尝试从您的代码中删除它并使用 CompletableFuture 代替。 https://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/util/concurrent/ListenableFutureCallback.html