HOME
Confluent Certified Developer for Apache Kafka

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

スキーマの進化において、すべての過去バージョンと互換性を保つ必要がある場合に設定すべき互換性レベルはどれか。

TRANSITIVE（推移的）設定を付与することで、直近だけでなく全ての履歴バージョンとの互換性がチェックさ…

2026年3月8日

Kafka Streamsにおいて、複数のソーストピックを結合して新しいストリームを作成する操作はどれか。

Join操作を使用することで、KStreamやKTableの間でキーに基づいたデータの統合が可能になる。

2026年3月8日

パーティションのLeaderがダウンした際、新しいLeaderを選出する役割を担うのはどれか。

Kafka Controllerはクラスタのメタデータを管理し、パーティションのLeader選挙を実行する。

2026年3月8日

プロデューサーのlinger.ms設定の主な目的はどれか。

linger.msを設定することで、バッチが溜まるのを少し待機し、ネットワークリクエスト数を減らして効率を高…

2026年3月8日

コンシューマーがメッセージの処理に失敗した場合に、同じメッセージを再度読み取るために必要な操作はどれか。

seekメソッドを使用することで、任意のオフセットからメッセージの読み取りを再開できる。

2026年3月8日

Kafkaクライアントとブローカー間の通信を暗号化するために使用されるプロトコルはどれか。

TLS/SSLを使用することで、ネットワーク上のデータ盗聴を防ぎ通信の安全性を確保できる。

2026年3月8日

ksqlDBにおいて、一度実行すると継続的に新しい結果を出力し続けるクエリの種類はどれか。

Push Queryはトピックに新しいデータが到着するたびにリアルタイムで結果をクライアントに送信する。

2026年3月8日

Kafka Streamsでウィンドウ処理を行う際、各レコードがどのウィンドウに属するかを決定する基準はどれか。

Kafka Streamsはデフォルトでレコードに埋め込まれたイベント時刻（Event Time）を使用してウィンドウを決…

2026年3月8日

Kafkaのディスク容量を節約するために、指定された保持期間を超えた古いデータを削除する仕組みはどれか。

log.cleanup.policy設定により、時間やサイズに基づいた古いデータの削除が行われる。

2026年3月8日

Schema Registryにおいて、スキーマを変更しても古いデータが新しいスキーマで読み取れることを保証する設定はどれか。

FORWARD互換性は新しいスキーマで書かれたデータを古いスキーマで読み取れることを保証する。

2026年3月8日