HOME
Confluent Certified Developer for Apache Kafka

「Confluent Certified Developer for Apache Kafka」の記事一覧

Schema Registryの「ID API」を使用して、スキーマIDからスキーマ定義を取得する際のエンドポイントはどれか。

IDはグローバルに一意であるため、Subjectを指定せずにIDから直接スキーマを引くことができる。

2026年3月8日

Kafka Streamsの「Interactive Queries」機能の主な用途はどれか。

RocksDBなどに保存されている集計の途中経過などを、REST APIなどを介して外部に公開できる。

2026年3月8日

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

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

2026年3月8日

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

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

2026年3月8日

トピックの設定「min.cleanable.dirty.ratio」は何を制御するか。

この値（デフォルト0.5）を超える未圧縮データが溜まると、クリーナースレッドが圧縮処理を開始する。

2026年3月8日

コンシューマーが「poll()」内で受け取るレコードの「timestampType」が「CreateTime」の場合、その値は何を指すか。

メッセージ送信時にプロデューサーが付与したオリジナルの時刻が維持されていることを示す。

2026年3月8日

Kafkaの認証メカニズム「SASL/OAUTHBEARER」を本番環境で実装する際、通常必要となる外部コンポーネントはどれか。

Kafka自身はトークンの発行を行わないため、JWTなどを発行・検証する外部のIDプロバイダーが必要である。

2026年3月8日

「Total Time Ms」メトリクスにおいて、リクエストが「Request Queue」で待機している時間を示す内訳項目はどれか。

この値が高い場合は、ブローカーのリクエストハンドラ（IOスレッド）が不足しているか、処理が詰まってい…

2026年3月8日

Kafka Connectの「offset.flush.interval.ms」は何を制御するか。

Sourceコネクタの進行状況をどれくらいの頻度でKafkaに記録するかを決定する。

2026年3月8日

Schema Registryの「Subject Name Strategy」で「TopicRecordNameStrategy」を選択した際の効果はどれか。

トピック名とレコードのフルネームを組み合わせることで、多様なデータが流れるトピックに対応できる。

2026年3月8日