HOME
Lv014

「Lv014」の記事一覧

Kafkaのメッセージに付与されるタイムスタンプの種類が「LogAppendTime」の場合、その時刻はいつ決まるか。

LogAppendTime設定では、プロデューサー側の時刻は無視され、ブローカー側の到着時刻が記録される。

2026年3月8日

Kafkaの「Delegation Token」を使用する主なメリットはどれか。

一度Kerberosで認証した後、軽量なトークンを発行することで、多数のクライアント接続による認証サーバー…

2026年3月8日

コンシューマーの「heartbeat.interval.ms」は、通常「session.timeout.ms」に対してどの程度の比率が推奨されるか。

タイムアウトまでに数回のハートビートを送る機会を設けることで、一時的なネットワークの揺らぎによる誤…

2026年3月8日

Kafkaブローカー間のデータ転送速度を制限し、再分散（Rebalancing）時のネットワーク負荷を抑えるために使用するツールや設定はどれか。

再割り当てツールにスロットルを指定することで、通常のトラフィックを阻害せずにパーティション移動を行…

2026年3月8日

ブローカーで「Request Handler Average Idle」メトリクスが低い（0に近い）場合に意味することはどれか。

Idleが低いということはスレッドが常に忙しく働いていることを示し、num.io.threadsの調整が必要な可能性…

2026年3月8日

Kafka Connectの「Error Handling」設定で、エラーレコードをスキップしつつログに記録するために設定する値はどれか。

tolerance=allを設定すると、エラーが発生してもタスクを停止せずに処理を続行できる。

2026年3月8日

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

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

2026年3月8日

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

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

2026年3月8日

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

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

2026年3月8日

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

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

2026年3月8日