HOME
Lv017

「Lv017」の記事一覧

トピックの設定「compression.type」が「uncompressed」の場合の挙動はどれか。

ブローカー側で解凍処理が発生するため、通常は「producer」設定にして透過的に扱うのが効率的である。

2026年3月8日

Javaクライアントのコンシューマーをスレッドセーフに使用するための正しい方法はどれか。

KafkaConsumerはスレッドセーフではないため、原則として1スレッド1インスタンスのモデルで設計する必要が…

2026年3月8日

クライアント証明書を使用したTLS認証（双方向TLS）において、ブローカーがクライアントを識別するために使用する情報はどれか。

ブローカーは証明書のDNからプリンシパル（ユーザー名）を抽出し、それをACLの照合に使用する。

2026年3月8日

「Controller Active Count」メトリクスが0になった場合に発生する現象はどれか。

データパス（既存パーティションへの読み書き）は継続できる可能性があるが、管理操作は麻痺する。

2026年3月8日

Kafka Connectのワーカーが「Out of Memory (OOM)」で停止する際、確認すべき設定はどれか。

ConnectはJVMプロセスとして動作するため、大量のデータを扱う場合は適切なヒープメモリの割り当てが必要…

2026年3月8日

Kafkaの「Jarkarta」などの大規模クラスタにおいて、ブローカーIDを自動的に割り振るための設定はどれか。

Zookeeper時代には自動採番があったが、KRaftではノードの役割を明確にするため手動でのID管理が一般的で…

2026年3月8日

Schema Registryにおいて、スキーマの特定のバージョンを「Soft Delete」した状態とはどのような状態か。

Soft Deleteされたスキーマは、既存データのデシリアライズには利用可能だが、新しいデータの登録には利用…

2026年3月8日

コンシューマーが「poll(Duration)」を呼び出した際、指定した時間が経過する前に戻ってくる条件はどれか。

fetch.min.bytesが満たされれば、タイムアウトを待たずに即座にデータをアプリに返す。

2026年3月8日

Kafka Streamsにおいて「Windowed Join」を実行する際、データの重複を防ぐために重要な要素はどれか。

ウィンドウ内のデータの一貫性を保ち、遅延データによる結果の不整合を防ぐために時間の管理が不可欠であ…

2026年3月8日

プロデューサーの「metadata.max.age.ms」は何を制御するか。

トピックの増分やリーダーの交代を検知するために、一定期間ごとに最新のクラスタ情報を取得する。

2026年3月8日