HOME
Confluent Certified Developer for Apache Kafka

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

Kafka Streamsにおいて「Stateless（状態なし）」な操作はどれか。

MapやFilterは各レコードを独立して処理するため、過去のデータを保持する状態ストアを必要としない。

2026年3月8日

Schema RegistryにProtobuf形式でスキーマを登録する際、参照（References）を使用する目的はどれか。

References機能により、複数のスキーマ間で定義を共有し、再利用性を高めることができる。

2026年3月8日

プロデューサーの「acks=all」設定時、書き込み成功とみなされるために必要なISRの数はどのように決まるか。

acks=allは、現在のISRに存在する全レプリカが受信することを求めるが、min.insync.replicasの数に達して…

2026年3月8日

コンシューマーが特定のタイムスタンプに基づいてメッセージを探すために使用するメソッドはどれか。

offsetsForTimes()に時刻を渡すと、その時刻以降の最初のメッセージのオフセットを取得できる。

2026年3月8日

トピックの「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日

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

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

2026年3月8日

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

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

2026年3月8日