3 つの kafka ノードの環境で scalein をテストします。各ノードにはレプリカでブローカーと ZooKeeper サービスがオンになっています。factor=2 2 つのノードでサービスがダウンした後、パーティションのリーダーは古いノードのままで、その唯一のノードに移動しませんでした。起きている
エラーメッセージが送信されます
エラー: パーティション 0 にはリーダーがありません。オフセットの取得をスキップ エラー: パーティション 2 にはリーダーがありません。オフセットの取得をスキップ エラー: パーティション 3 にはリーダーがありません。オフセットの取得をスキップ
なぜこれが起こり得るのですか？
