我不得不使用SpringKafka（没有Spring！疯狂？但它是真的：）），我有下面的场景：配置了自动提交的使用者是记录侦听器（非批处理）;侦听器可以抛出两种类型的异常：BackoffException和GeneralSystemException。在发生BackoffException时，错误处理程序应该查找分区，暂停分区，并且不提交记录;在发生GeneralSystemException时，它应发送到另一个延迟主题并提交偏移量。
即使对于BackoffException，问题也是这样的，因为isAckAfterHandling为true，所以正在提交偏移量。如果我将其设置为false，另一个异常也会有问题。
我找到的一个解决方法是：创建一个自定义的常见错误处理程序，保持isAckAfterHandling = true，执行查找并暂停，如果发生BackoffException，则返回一个Exception;
但是我想知道Spring是如何自动引导这种场景的，例如，你有一个使用者使用KafkaBackoffAwareMessageListenerAdapter和DefaultErrorHandler作为错误处理程序，并且auto commit = true。查看代码，看起来处理程序会正确地寻找，但是会提交导致BackoffException的偏移量。如果重新平衡，消息会丢失。
就像我说的，如果我使用一个自定义的错误处理程序，在BackoffException的情况下，向容器抛出一个错误（在执行seek和pause之后），这解决了我的问题，但看起来像是一个变通方案。
我相信如果Spring有一个isAckAfterHandle（异常前），应该可以解决这种问题。
事实证明，按照设计，我们应该总是为未恢复的记录返回异常，所以我的解决方案最终不是我所说的变通方案。