需要帮助。我需要确认ksql如何处理以下错误：

org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.?

因为我们在引进新经纪人时遇到了麻烦。高容量拖缆进入错误状态，无法恢复，也不会被杀死。这几乎持续了几天，直到一些客户抱怨他们没有收到通知。我们通过注册一个重新启动流的全局异常处理程序来处理此场景：

streams.setUncaughtExceptionHandler((Thread thread, Throwable throwable) -> {
// here you should examine the throwable/exception and perform an appropriate action!
});

我们现在正计划为一些用例调整ksql。但主要关注的是如何在ksql中处理这种情况。有人能提出一些Maven意见吗。
这个问题很难复制。我试图在本地经营多家经纪公司，并杀死了领头羊，但我的制作人失败了，而消费者工作得很好。所以很难复制同样的东西，这就是为什么在这里征求Maven的意见，他在ksql中确实遇到过类似的问题。