Distributed computing Advent Calendar 2017の12/16分の投稿です。 qiita.com clientコードでよく使われるテクニック、というわけではなく 自分が勝手によく使っている小技の紹介です。 今回扱うKafka Java Clientのバージョンは1.0ではなく残念ながら0.10.…

今更ながら躓いたので動作チェックのメモ。 import org.junit.Test; import java.util.ArrayList; import java.util.List; ・・・ /** * オブジェクト同士が同じオブジェクトか判断するとき * hashCode()がオーバーライドされていて使えないときは * System.…

KafkaにはLog Compactionという機能があります。バージョン0.8.1から導入されました。 このLog Compaction、かなりとっつきづらい機能なんじゃないかと思っています。Kafkaドキュメントのこのセクションhttps://kafka.apache.org/documentation/#compaction…