HOME
Lv020

「Lv020」の記事一覧

べき等プロデューサーを使用している際、1つのバッチ内で一部のメッセージだけがブローカーに書き込まれることはあるか。

Kafkaのプロデューサーバッチは、ブローカー側でアトミックに処理されるため、バッチ内での一部欠損は起こ…

2026年3月8日

コンシューマーがメッセージを「読み飛ばす」ために、現在の位置を末尾（最新）まで強制的に移動させるメソッド呼び出しはどれか。

特定のパーティションの読み取りを最新位置まで一気に進めたい場合に利用される。

2026年3月8日

ブローカーの「background.threads」の主な仕事はどれか。

システム維持のための様々なルーチンワーク（ハウスキーピング）を実行する。

2026年3月8日

KRaftモードでブローカーを完全に削除（登録解除）するために使用するコマンドはどれか。

コントローラーのメタデータから対象ブローカーの情報を完全に削除する際に使用する。

2026年3月8日

「MirrorMaker 2」において、ハートビートトピック（__heartbeat）の目的はどれか。

定期的にハートビートを流すことで、パイプラインが生きており正常に動作しているかを確認する。

2026年3月8日

Kafkaの「Idempotent Producer」が保証できないのはどれか。

べき等性だけでは単一パーティション内のみの保証となり、複数パーティション・トピックの整合性にはトラ…

2026年3月8日

「Partition Assignor」において、コンシューマーの「Rack ID」を考慮してレプリカに近いノードを割り当てるのはどれか。

データの物理的な位置を考慮して、ネットワークコストの低いコンシューマーを割り当てる。

2026年3月8日

「log.segment.bytes」を小さく（例：100MB）設定した場合のブローカーへの影響はどれか。

多数の小さなファイルが作成されるため、ファイルシステムの管理コストが増大する。

2026年3月8日

Kafkaの「Credential Store」として外部のVault等を使用する場合、設定ファイル内にパスワードを直接書かないために利用する仕組みはどれか。

ConfigProviderインターフェースを実装することで、実行時に外部ソースから設定値を動的に取得できる。

2026年3月8日

「producer.purgatory.purge.interval.requests」は何を制御するか。

完了したリクエストをメモリから定期的に整理するための閾値を指定する。

2026年3月8日