HOME
Lv013

「Lv013」の記事一覧

トピックの「min.insync.replicas」が2で、レプリケーションファクタが3のとき、2台のブローカーがダウンするとどうなるか。

ISRが1台（Leaderのみ）になるため、minを満たせずacks=allのリクエストはエラーとなるが、読み取りは継続…

2026年3月8日

コンシューマーで「at-most-once（最大1回）」の配信保証を実現するための設定はどれか。

メッセージを処理する前にオフセットがコミットされる可能性を作ることで、失敗時に再読み込みをしない（…

2026年3月8日

Kafkaのプロトコル名「SASL_SSL」は何を意味するか。

この設定は本番環境で最も一般的な、セキュアな接続プロトコルの1つである。

2026年3月8日

Kafka Connectの「Converter」において、「schemas.enable=false」に設定したJSONConverterは何を出力するか。

falseに設定すると、スキーマ情報（"schema": ...）が省略され、通常のJSON形式のペイロードのみが送受信…

2026年3月8日

Schema Registryの互換性チェックをクライアント側で行うためのツールはどれか。

ビルド時にMavenなどのプラグインを使用することで、レジストリに登録済みのスキーマと互換性があるかを事…

2026年3月8日

Kafkaの「Network Processor」スレッドの役割はどれか。

ネットワークスレッドがリクエストを迅速に受け取ることで、背後のIOスレッド（Request Handler）が処理に…

2026年3月8日

Kafka Streamsにおいて、KTable同士をJoinする際に「Foreign Key Join」が必要になるのはどのような場合か。

主キー以外を条件に結合する場合にForeign Key Joinを使用し、内部的に再分配処理が行われる。

2026年3月8日

Kafkaの「Controller」が担う主なタスクのうち、誤っているものはどれか。

オフセットの保存は__consumer_offsetsトピックへの書き込みとして各ブローカーが担当し、コントローラー…

2026年3月8日

Javaクライアントでプロデューサーがメッセージ送信後にコールバック（Callback）を受け取る利点はどれか。

コールバックを使用することで、送信リクエストを投げ続けながら、完了時のエラー処理などを効率的に行え…

2026年3月8日

コンシューマーがオフセットをコミットする際、次に読み取るべき位置として記録されるのはどれか。

Kafkaのオフセットは「次に読み始める位置」を指すため、処理済み末尾の次をコミットする。

2026年3月8日