apache kafka 安装

kafka官网下载 kafka_2.10-0.8.2.1.tgz并复制到虚拟机Ubuntu
2.1解压到该路径
tar zxvf kafka_2.10-0.8.2.1.tgz
sudo mv kafka /home/chen-pc/kafka
启动和停止
启动Zookeeper server：
Shell代码
bin/zookeeper-server-start.sh config/zookeeper.properties &
其中&是为了能退出命令行

停止Kafka server
Shell代码
bin/kafka-server-stop.sh
出现如下：
INFO Shutting down. (kafka.log.LogManager)
INFO Shutdown complete. (kafka.log.LogManager)
INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
INFO Session: 0x154957ee6bc0000 closed (org.apache.zookeeper.ZooKeeper)
INFO EventThread shut down (org.apache.zookeeper.ClientCnxn)
INFO [Kafka Server 0], shut down completed (kafka.server.KafkaServer)

停止Zookeeper server:
Shell代码
bin/zookeeper-server-stop.sh
出现如下：
[1]+ Exit 130 bin/zookeeper-server-start.sh config/zookeeper.properties

4.创建启动、关闭kafka脚本
cd /home/chen-pc/kafka

创建启动脚本
vi kafkastart.sh #编辑，添加以下代码
#!/bin/sh
#启动zookeeper
/home/chen-pc/kafka/bin/zookeeper-server-start.sh /home/chen-pc/kafka/config/zookeeper.properties &
#等3秒后执行
sleep 3
#启动kafka
/home/chen-pc/kafka/bin/kafka-server-start.sh /home/chen-pc/kafka/config/server.properties &
保存退出

vi kafkastop.sh #编辑，添加以下代码
#!/bin/sh
#关闭zookeeper
/home/chen-pc/kafka/bin/zookeeper-server-stop.sh /home/chen-pc/kafka/config/zookeeper.properties &
sleep 3
#关闭kafka
/home/chen-pc/kafka/bin/kafka-server-stop.sh /home/chen-pc/kafka/config/server.properties &

添加脚本执行权限
chmod +x kafkastart.sh
chmod +x kafkastop.sh

以后启动kafka
sh /home/chen-pc/kafka/kafkastart.sh
Jps查看进程

关闭kafka
sh /home/chen-pc/kafka/kafkastop.sh
至此，Linux下Kafka单机安装配置完成。
4. 单节点kafka
sh /home/chen-pc/kafka/kafkastart.sh

Kafka创建topic
cd kafka
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

Kafka 删除topic
bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

查看topic
/home/chen-pc/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181

启动consumer & producer，并在producer启动后的console输入一些信息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

Kafka安装部署成功

---

　　https://my.oschina.net/gemron/blog/830297#comment-list
看这篇 中文翻译的文档 希望能帮到你