如何解决在Java中自动重启Kafka Stream
我面临的问题是我的Kafka Stream(1线程)由于某些错误而意外关闭。我想做的是,如果Kafka流使用者中存在错误,则将其识别并通过cron自动重新启动该流,从而消除了对其进行持续监视的麻烦。有什么合适的方法吗?
直到现在,我已经尝试在发生错误的同一流实例上使用stream.start()
,但是它没有用。
解决方法
您现在无法重用流。但是,在2.8(几个月后)中,有计划允许在处理程序中替换流线程。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。