+++ date = "2015-08-31T15:53:58+09:00" draft = true title = "Go言語でApache KafkaのProducerとConsumerを書く" +++ 最近仕事でApache Kafkaの導入を進めている.その練習としてKafkaのProducerとConsumerをGo言語で実装してみたのでそれについてつらつらと書いてみる. ConsumerがPull型であるのもKafkaの特徴である.これによりConsumerの処理能力やネットワーク帯域に合わせてメッセージ流量を調整することができる. http://kafka.apache.org/documentation.html#theconsumer ProducerとConsumerを書く このProducerとConsumerはlogstashやfluentdのoutput/inp