HOME
Confluent Certified Developer for Apache Kafka

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

プロデューサーの「buffer.memory」設定は何を制御するか。

このメモリが不足すると、プロデューサーのsend()呼び出しはmax.block.msの間ブロックされる。

2026年3月8日

コネクタ設定において「tasks.max」は何を制限するか。

tasks.maxは、そのコネクタがワークロードを並列化するために起動できる最大のスレッド数を指定する。

2026年3月8日

コンシューマーが「__consumer_offsets」トピックに直接書き込みを行うのはどのような時か。

__consumer_offsetsはコンシューマーの進行状況を永続化するための内部トピックである。

2026年3月8日

トピックのセグメントファイルがロール（新しく作成）される条件はどれか。

log.segment.bytesまたはlog.roll.hoursの設定に基づき、古いセグメントがクローズされ新しいファイルが作…

2026年3月8日

Kafka Streamsにおける「State Store」のデフォルトのストレージエンジンはどれか。

RocksDBは永続化と高速なアクセスを両立する埋め込み型のKey-Valueストアとして標準利用される。

2026年3月8日

enable.idempotence=trueの場合、内部的に各メッセージに付与される2つの識別子はどれか。

PID（Producer ID）とシーケンス番号により、ブローカーはメッセージの重複や欠落を検知できる。

2026年3月8日

コンシューマーのオフセットコミットを同期的に行うメソッドはどれか。

commitSync()はコミットが完了するまでスレッドをブロックし、失敗した場合はリトライを試みる。

2026年3月8日

Kafka Connectの内部トピック「config.storage.topic」のパーティション数は通常いくつに設定すべきか。

設定情報の整合性を保ち順序を保証するため、構成トピックは単一パーティションである必要がある。

2026年3月8日

SSL/TLS通信において、クライアントがブローカーを信頼するために必要なファイルはどれか。

TrustStoreにはブローカーの証明書を署名したCAの証明書が含まれており、接続先の正当性を検証する。

2026年3月8日

ブローカーのログディレクトリが複数ある場合、Kafkaは新しいパーティションをどのように配置するか。

Kafkaはディスク間の負荷バランスを取るため、管理しているパーティション数が最も少ないディレクトリを選…

2026年3月8日