*) 安装和测试

cd /path/to/server
#) 下载kafka二进制包
wget http://apache.fayea.com/apache-mirror/kafka/0.8.1.1/kafka_2.9.2-0.8.1.1.tgz
#) 解压缩kafka包
tar -zxvf kafka_2.9.2-0.8.1.1.tgz
#) 构建软连接到目录kafka
ln -s kafka_2.9.2-0.8.1.1 kafka

#) 开启zookeeper-server服务
bin/zookeeper-server-start.sh config/zookeeper.properties &> /dev/null &
#) 开启kafka-server服务
nohup ./bin/kafka-server-start.sh config/server.properties &> /dev/null &

#) 进程验证
jps 查询

评注:
　　QuorumPeerMain 为对应的单个Zookeeper实例
　　Kafka 为对应的Kafka实例

netstat 查询

评注:
　　2181 为zookeeper的监听端口
　　9092 为kafka的监听端口

#) 创建topic:test
bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test

#) 列出已创建的topic列表
bin/kafka-topics.sh --list --zookeeper localhost:2181

#) 模拟客户端去发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

#) 模拟客户端去接受消息
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

简单的一个kafka过程, 还是很容易的

参考官方文档
http://kafka.apache.org/documentation.html