kafka-python
という良く整備されているライブラリがある。これを利用したプログラムを作る。そうすると自動的に、ユニットテストで kafka が欲しくなる。
どうやるか?というと、Java では色々な技が編み出されているらしい。
http://qiita.com/kmizumar/items/60c60284501bda111065
だがしかし python ライブラリではどうするか?……というと、kafka-python
自身では subprocess で kafka を起動させていた。
https://github.com/dpkp/kafka-python/blob/master/test/fixtures.py#L23
kafka のバイナリ配布物には簡単設定の起動ファイルがあるけれど、kafka-python
では自前の設定ファイルを使って起動させている。bind するポートなどをパラメータ設定できるようにするためで、それ以上の何かは無さそう。
とっても簡単なライブラリであれば、バイナリ配布物の設定ファイルでテストすればいいかな。