我们正在使用 Hazelcast Jet 0.4 版本从 Kafka Source 读取消息，处理消息并写入 Kafka。由于 Kafka 由外部团队管理，我们无法控制 Kafka 中抛出的各种异常。
例如，我们收到以下异常：由于组已经重新平衡并分配了分区，因此无法完成提交
当我们收到此错误时，Hazelcast Jet 实例已关闭。所以我们的应用程序变得不可用，我们必须重新启动应用程序。
我们正在研究在这些错误期间自动重新启动 Jet 实例的可能性。
谢谢你的帮助！
问问题
61 次
1 回答
0
看起来您遇到了这个问题：https ://github.com/hazelcast/hazelcast-jet/issues/428 。它在当前 Jet 版本中已修复，其中使用手动分区分配，即使事件处理非常慢也不会导致心跳超时。
于 2018-07-04T06:32:27.983 回答