我们正在使用hazelcast jet0.4版本来读取来自kafka源代码的消息，处理这些消息并将其写入kafka。由于kafka是由外部团队管理的，因此我们无法控制kafka中抛出的各种异常。
例如，我们收到以下异常：提交无法完成，因为组已经重新平衡并分配了分区
当我们收到此错误时，hazelcast jet示例被关闭。因此，我们的应用程序变得不可用，我们必须重新启动应用程序。
我们正在研究在这些错误期间自动重新启动jet示例的可能性。
谢谢你的帮助！
我们正在使用hazelcast jet0.4版本来读取来自kafka源代码的消息，处理这些消息并将其写入kafka。由于kafka是由外部团队管理的，因此我们无法控制kafka中抛出的各种异常。
例如，我们收到以下异常：提交无法完成，因为组已经重新平衡并分配了分区
当我们收到此错误时，hazelcast jet示例被关闭。因此，我们的应用程序变得不可用，我们必须重新启动应用程序。
我们正在研究在这些错误期间自动重新启动jet示例的可能性。
谢谢你的帮助！
1条答案
按热度按时间w3nuxt5m1#
看起来您正遭受此问题的困扰：https://github.com/hazelcast/hazelcast-jet/issues/428. 在当前的jet版本中，它是固定的，在这个版本中使用了手动分区分配，即使处理非常慢的事件也不会导致心跳超时。