spring-kafka
-
Spring Kafka 该类不在受信任的包中 在库更新之前的Spring Boot/Kafka应用程序中,我使用以下类来向Kafka主题发布消息。现在我使用以下.如您所见 - 它们具有不同的包。 应用程序重新启动后,我遇到了以下问题:
-
如何在弹簧卡夫卡中确认当前偏移以进行手动提交 我第一次使用Spring Kafka,我无法在我的消费者代码中使用Ressless.acknowledge()方法进行手动提交。如果我的使用者配置或监听器代码中缺少任何内容,请告诉我。或者有其他方法来处理基于条件
-
处理 Kafka 流中的异常 已经经历了多个帖子,但其中大多数是相关的处理坏消息,而不是处理它们时的异常处理。 我想知道如何处理流应用程序收到的消息,并且在处理消息时出现异常?例外情况可能是由于多种原因
标签