Apache Kafka：在主题中重播消息
共有1个答案
是的，您可以寻求特定的偏移量，但是
时间开端
取决于主题或代理配置。IIRC，默认保留时间为7天。
-
使用Spring云流上通道的标准配置，消息重试3次，然后跳过。如果以下消息处理成功完成，则提交偏移量。这意味着在瞬态异常情况下，消息可能会丢失。 是否可以更改此行为，从而使通道卡在失败消息上，直到修复瞬态条件？ 我已经尝试配置重试模板，但您必须指定多次重试，这看起来像是一个无用的参数，因为所需的行为将永远重试。 有人卷入这些麻烦吗？非常感谢。 我还怀疑这会如何干扰max.poll。间隔ms属性。
-
我一直在寻找了解这 3 个： 主题 行为主体 重播主题 我想使用它们，并知道何时、为什么使用它们，使用它们有什么好处，尽管我已经阅读了文档、观看了教程并搜索了谷歌，但我对此没有任何理解。 那么他们的目的是什么？一个真实的案例将是最受欢迎的，它甚至不需要编写代码。 我更喜欢一个干净的解释，而不仅仅是“a b = 非常感谢。
-
生产者发送消息到一个有四个分区的主题。我们有一个消费者在消费来自这个主题的消息。应用程序在工作日一直运行周末例外：它不会在周末期间调用poll方法。 使用者配置：自动提交，自动提交时间为5s（默认）。 应用程序一直运行良好，直到一个星期天，当它重新开始调用poll方法。我们看到有数百万条消息从这个话题中被轮询出来。消费者基本上是轮询来自主题的所有消息。将新的偏移量与它在周末停止之前的偏移量进行比较
-
然而，当在我的环境中测试此示例时，我得到了一个异常。
-
我需要一个Kafka主题存储的消息数量。这与任何消费者是否消费了消息无关。 以上是否等于Kafka主题中当前存储的消息数？
-
我在kafka中面临一个奇怪的问题，即在消费者应用程序重新启动后，所有来自主题的kafka消息都在重播。有人能帮我我在这里做错了什么吗？ 这是我的配置： spring.kafka.consumer.auto-偏移-重置=最早 spring.kafka.enable.auto。提交=false 我的生产者配置： 消费者配置： 消费者代码： 集装箱代码 消费者配置 应用程序.属性