在Kafka侦听器方法中发生异常时不提交偏移量
请帮助我决定这是否是正确的方法。我使用的不是Spring kafka 2.x，而是1.2.x。另外，目前我已经将auto.commit.offset属性设置为false，并将ackMode设置为manual。
共有1个答案
不再支持1.2.x；您应该尽快升级到至少1.3.10；它有一个简单得多的线程模型，这要归功于KIP-62。
当前版本为2.3.0。
2.0.1正是为了这个目的引入了SeekToCurrEnterrorHandler。
-
我正在实现spring kafka批处理侦听器，它读取来自kafka主题的消息列表，并将数据发布到REST服务。我想了解在REST服务停止的情况下的偏移管理，不应该提交批处理的偏移，应该为下一次轮询处理消息。我已经阅读了spring kafka文档，但在理解侦听器错误处理程序和批量查找当前容器错误处理程序之间的区别时存在困惑。我使用的是spring-boot-2.0.0。M7及以下版本是我的代码。
-
null 当侦听器处理记录后返回时提交偏移量。 如果侦听器方法抛出异常，我会认为偏移量不会增加。但是，当我使用下面的code/config/command组合对其进行测试时，情况并非如此。偏移量仍然会得到更新，并且继续处理下一条消息。 我的配置： 验证偏移量的命令： 我使用的是kafka2.12-0.10.2.0和org.springframework.kafka:spring-kafka:1.1
-
我目前正在从具有特定偏移量的主题中获取消息。我正在使用寻求（）来实现它。但是当我将enable.auto.commit设置为true或使用手动同步（委托同步（）/委托同步（））时，Seek（）不起作用，因为它没有轮询来自特定偏移量的消息，而是从最后提交的偏移量中选择。 因此，在使用Seek（）时，是否必须将偏移量存储在外部DB中，而不提交给Kafka？Seek和Commit不能并行工作吗？ 客户端
-
我使用的是Spring Kafka 1.2.2版。我有一个Kafka Listener作为消费者，它监听一个主题并在弹性中索引文档。我的自动提交偏移量属性设置为true//default。
-
我有一个Kafka消费者，我从它消费数据从一个特定的主题，我看到下面的例外。我使用的是Kafka版本。 我添加了这两个额外的消费者属性，但仍然没有帮助： 那个错误意味着什么？我该如何解决它？我需要添加一些其他消费者属性吗？
-
我有一个ReactorKafka项目，它消耗来自Kafka主题的消息，转换消息，然后写入到另一个主题。 我的理解是，只有在Reactor中成功完成所有顺序步骤后，才会提交偏移量。对吗？我想确保不会处理下一条记录，除非当前记录成功发送到目标Kafka主题。