Litmus を使用してカフカをテストすることは可能ですか? 基本的に、さまざまなシナリオで何が起こるかを把握するためのテストです。最初の考えは次のとおりです。
- kafka のコンフルエント ヘルム チャートをデプロイし、ブローカーをチェックすると、ストレージが正常にバインドされます
- ブローカーを強制終了し、それが戻ってくることを確認します
- Zookeeper pod を強制終了し、確実に戻ってくるようにする
- コンシューマー ポッド (自分のアプリ) を強制終了し、それらが戻ってきてメッセージを見逃さないようにする
- プロデューサー ポッドを強制終了し、それが戻ってくることを確認し、すべてのメッセージが送信されることを確認します。