Kafka

p.4 Kafka のデータの単位は公式には「メッセージ」。でも Java のクラス名は ProducerRecord

p.23 ログセグメントは log.dirs で指定したディレクトリに保存されるが、複数のディレクトリを指定すると、新しいパーティションは最もパーティション数が少ないディレクトリに保存される。最も容量が少ないディレクトリではない。ある程度均等にしたければ、パーティションサイズの設計に工夫が必要。

p.23 auto.create.topics.enable は練習用途以外では false にすべきである。

p.25 作者の見解ではパーティションサイズは1日あたり 6GB 未満にすべき。1MB/s を標準的な処理速度とすると1日あたり 86400MB 処理できるので、ピークタイムに10倍のトラフィックがあると考えた場合だろうか。

pp.26-27 log.retension.ms や log.retension.bytes による期限切れ削除は log.segment.bytes (=1GB) のセグメントごとに実行される。流量があまりにも小さいパーティションではデータが全然削除されないということが起きる。データ破棄が重要な要件の場合は log.segment.ms を設定するとよいかもしれない。

p.54 schema registry は topic に非互換なスキーマのメッセージが入らないことを保証するためのランタイムな門番としての役割である。どの producer/consumer がどのバージョンのスキーマで読み書きしているか一覧性をもって把握することが運用上重要らしい。

p.82 Kafka メッセージを取ってきて都度処理した結果を DB に exactly-once で書き込みたいとする。この場合は Kafka のオフセットを DB に保存するというテクニックが使える。初期化時に seek でオフセットをずらせばよい。