Distributed computing Advent Calendar 2017の12/16分の投稿です。 qiita.com clientコードでよく使われるテクニック、というわけではなく 自分が勝手によく使っている小技の紹介です。 今回扱うKafka Java Clientのバージョンは1.0ではなく残念ながら0.10.1.1です・・・今キャッチアップしてないんですよね。 他にいい小技や改善案などあればコメントで教えてください。 RPS調整(EPS) サンプリング RPS調整とサンプリングの合わせ技 トピック毎の流量調整(おまけ) 考え方 処理スレッドを増やす オフセット強制最新 batch consumer(startとstop) consumerの割当はconsumer groupの機能を使い、それ以降は使わずに固定する おわり RPS調整(EPS) Kafkaは一般に流量に強