kafka golang github.com/Shopify/

https://github.com/Shopify/sarama
https://godoc.org/github.com/Shopify/sarama

看官网，跑例子

bash1: bin/zookeeper-server-start.sh config/zookeeper.properties
bash2: bin/kafka-server-start.sh config/server.properties
# 这里的important是github.com/Shopify/sarama里example的topic名字
bash3: bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic important --from-beginning

http://kafka.apache.org/quickstart

go get github.com/Shopify/sarama

cd $GOPATH/github.com/Shopify/sarama/example
go build
./http_server -brokers 127.0.0.1:9092[,other brokers]

3的那个例子默认跑在8080端口，访问http://IP:8080/?age=18
就可以从步骤1里的bash3里看到age=18