java – Kafka Streams：错误退出的正确方法
发布时间：2020-12-15 01:09:02 所属栏目：Java 来源：网络整理
导读：我已经成功地获得了一个使用,转换和生成数据的流应用程序,但我注意到,流处理器会定期转换到ERROR状态,并且该进程将在不退出的情况下停留在那里. 显示我的日志： 所有流线程都已经死亡.该实例将处于错误状态,应该关闭. 有没有办法告诉Streams应用程序一旦达到
|
我已经成功地获得了一个使用,转换和生成数据的流应用程序,但我注意到,流处理器会定期转换到ERROR状态,并且该进程将在不退出的情况下停留在那里. 显示我的日志： 所有流线程都已经死亡.该实例将处于错误状态,应该关闭. 有没有办法告诉Streams应用程序一旦达到ERROR状态就退出？也许是各种监视器线程？ 我看到Kafka Streams代码的注释中的references给需要在应用程序达到此状态时关闭应用程序的用户,但是,我还没有在文档中找到提及此任务的内容. 有没有一种简单的方法来执行此关闭步骤？ 可能是错误的方式可能关闭错误 我的目的是在KafkaStreams对象上设置UncaughtExceptionHandler方法,以执行以下操作： >记录错误 结果是： >记录异常消息 然后,不幸的是,这个过程似乎没有退出. FWIW我觉得这可能是对setUncaughtExceptionHandler的误用 最佳答案
使用UncaughtExceptionHandler是正确的.但是,如果在处理程序回调中调用KafkaStreams#close(),则可能会遇到死锁.因此,您应该只设置一个标志,并在回调之外调用#close(),或者使用close()和超时.如果超时到期,则强制关闭.
（编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |