因为Kafka 依赖ZooKeeper,所以需要先安装ZooKeeper。
ZooKeeper
安装ZooKeeper,并设置dataDir
$ wget http://mirrors.cnnic.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
$ tar zxvf zookeeper-3.4.6.tar.gz
$ cd zookeeper-3.4.6
$ cp -rf conf/zoo_sample.cfg conf/zoo.cfg
$ vim conf/zoo.cfg
启动ZooKeeper
$ sh bin/zkServer.sh start
Kafka
安装并运行Kafka
$ wget http://apache.fayea.com/kafka/0.8.2.1/kafka_2.10-0.8.2.1.tgz
$ tar -zxf kafka_2.10-0.8.2.1.tgz
$ cd kafka_2.10-0.8.2.1
$ sh bin/kafka-server-start.sh config/server.properties
创建Topic
$ sh bin/kafka-topics --create --topic kafkatopic --replication-factor 1 --partitions 1 --zookeeper localhost:2181
查看Topic
$ sh bin/kafka-topics --list --zookeeper localhost:2181
启动Producer 生产消息
$ sh bin/kafka-console-producer --broker-list localhost:9092 --topic kafkatopic
启动Consumer 消费消息
$ sh bin/kafka-console-consumer --zookeeper localhost:2181 --topic kafkatopic --from-beginning
删除Topic
$ sh bin/kafka-run-class kafka.admin.TopicCommand --delete --topic kafkatopic --zookeeper localhost:2181
查看Topic 的offset
$ sh bin/kafka-consumer-offset-checker --zookeeper localhost:2181 --topic kafkatopic --group consumer
Kafka 的数据在Zookeeper 节点的 /var/local/kafka/data 目录中,以topic 作为子目录名。