如果 SeekToCurrentErrorHandler 中的 ConsumerRecordRecoverer 抛出异常会发生什么
What happens if ConsumerRecordRecoverer in SeekToCurrentErrorHandler throws exception
我只是想知道如果SeekToCurrentErrorHandler 中的ConsumerRecordRecoverer 抛出异常怎么办？我看到了代码，根据我的理解，如果发生这种情况，记录将再次重播。我的理解对吗？
有没有办法更好地处理这个问题？就像在恢复器失败时捕获该特定异常并记录该异常并捕获该指标并继续？
您的理解是正确的；该框架不能在这里做出任何假设，因此如果恢复器未能 "recover" 记录并重播它，它会采取保守的方法。
在许多情况下（例如未能将失败发布到死信主题）这将是所需的行为。
如果这不是您想要的，您需要将逻辑放入恢复器中。
我只是想知道如果SeekToCurrentErrorHandler 中的ConsumerRecordRecoverer 抛出异常怎么办？我看到了代码，根据我的理解，如果发生这种情况，记录将再次重播。我的理解对吗？
有没有办法更好地处理这个问题？就像在恢复器失败时捕获该特定异常并记录该异常并捕获该指标并继续？
您的理解是正确的；该框架不能在这里做出任何假设，因此如果恢复器未能 "recover" 记录并重播它，它会采取保守的方法。
在许多情况下（例如未能将失败发布到死信主题）这将是所需的行为。
如果这不是您想要的，您需要将逻辑放入恢复器中。