1、下载kafka安装包

wget http://mirrors.cnnic.cn/apache/kafka/0.8.2.1/kafka_2.11-0.8.2.1.tgz

2、复制到安装目录

cp kafka_2.11-0.8.2.1.tgz /usr/local/

3、解压

cd /usr/local/

tar -zxvf kafka_2.11-0.8.2.1.tgz

4、修改配置

cd kafka_2.11-0.8.2.1

cd config

vi server.properties

进行host配置，如需被其它主机调用可配置IP

host.name=localhost

6、启动

#启动zookeeper

/usr/local/kafka_2.11-0.8.2.1/bin/zookeeper-server-start.sh /usr/local/kafka_2.11-0.8.2.1/config/zookeeper.properties > /var/tmp/zk-server-start.log &

#启动kafka

/usr/local/kafka_2.11-0.8.2.1/bin/kafka-server-start.sh /usr/local/kafka_2.11-0.8.2.1/config/server.properties > /var/tmp/kafka-server-start.log &

7、测试

#producer

/usr/local/kafka_2.11-0.8.2.1/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

#consumer

/usr/local/kafka_2.11-0.8.2.1/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

在 producer 输入： message

在 consumer 显示： message

表示已安装启动成功

#创建topic test2

/usr/local/kafka_2.11-0.8.2.1/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2

#列出当前的所有topic

/usr/local/kafka_2.11-0.8.2.1/bin/kafka-topics.sh --list --zookeeper localhost:2181