HOME
Confluent Certified Developer for Apache Kafka

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

Kafka Streamsにおいて、同じキーを持つデータが異なるパーティションに存在する場合、Joinの前に実行される処理はどれか。

Joinの条件を満たすために、内部トピックを使用してデータを再分配（Repartition）し、キーを同じパーティ…

2026年3月8日

ブローカーが正常にシャットダウンされる際に、リーダーシップを他のブローカーへ移譲する機能を何と呼ぶか。

Controlled Shutdownを有効にすると、停止時のダウンタイムを最小限に抑えることができる。

2026年3月8日

トランザクションを使用して複数のトピックへの書き込みをアトミックに行う際、プロデューサーに設定が必要な一意のIDはどれか。

transactional.idを設定することで、プロデューサーの再起動後もトランザクションの状態を継続できる。

2026年3月8日

トランザクションプロデューサーによって書かれたメッセージを、コミットされたもののみ読み取るためのコンシューマー設定はどれか。

read_committedを指定すると、コミット済みのメッセージまたはトランザクション外のメッセージのみが読み…

2026年3月8日

トピックのパーティション数を増やす際の主な影響として正しいものはどれか。

パーティション数が増えるとハッシュ計算の結果が変わるため、同じキーを持つメッセージが異なるパーティ…

2026年3月8日

SASL/SCRAM認証を使用する際、ユーザー名とパスワード情報はどこに保存されるか（KRaft構成）。

KRaftモードでは、ユーザーの資格情報もメタデータログの一部としてクラスタ内で管理される。

2026年3月8日

コンシューマーグループのメンバーが長時間poll()を呼び出さなかった場合に、グループから除外されるまでの時間を決める設定はどれか。

max.poll.interval.msは処理に時間がかかりすぎているコンシューマーを検知するための設定である。

2026年3月8日

Kafka Connectの分散モード（Distributed Mode）において、クラスタの状態（オフセットや構成）を共有するために使用されるのはどれか。

分散モードのKafka Connectは、自身の状態情報を専用のKafkaトピックに保存してメンバー間で共有する。

2026年3月8日

JMXメトリクスのうち、ブローカーがリクエストの処理にどれだけ時間を費やしているかを確認するために重要な指標はどれか。

TotalTimeMs（またはRequestTotalTime）は、リクエストの受付から応答までの全時間を表す重要な指標である…

2026年3月8日

スキーマのIDはKafkaメッセージのどの部分に格納されるのが一般的か。

Confluent形式では、マジックバイト(0)と4バイトのスキーマIDがバリューの先頭に付与される。

2026年3月8日