出现异常时重启 Hazelcast Jet (v0.4)

Question

我们正在使用 Hazelcast Jet 0.4 版本从 Kafka Source 读取消息，处理消息并写入 Kafka。 由于 Kafka 由外部团队管理，我们无法控制 Kafka 中抛出的各种异常。

例如，我们收到以下异常：提交无法完成，因为该组已经重新平衡并分配了分区

当我们收到此错误时，Hazelcast Jet 实例已关闭。所以我们的应用程序变得无法使用，我们必须重新启动应用程序。

我们正在研究在这些错误期间自动重新启动 Jet 实例的可能性。

感谢您的帮助！

Answer 1

您似乎遇到了这个问题：https://github.com/hazelcast/hazelcast-jet/issues/428。在使用手动分区分配的当前 Jet 版本中已修复，即使事件处理非常慢也不会导致心跳超时。