*) 安装和测试
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