CentOS Zookeeper+Kafka单机搭建

1.安装Zookeeper

wget
 http://mirrors.cnnic.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz[/code] 
解压文件到/Usr/local下：

tar zxvf zookeeper-3.4.6.tar.gz -C /usr/local


配置文件加入dataDir，文件须自己创建，其他不变：

cd  /usr/local/zookeeper-3.4.6/conf

cp -rf zoo_sample.cfg  zoo.cfg

vim  zoo.cfg

dataDir=/usr/local/zookeeper-3.4.6/zkdata


启动：

cd /usr/local/zookeeper-3.4.6/bin


./zkServer.sh start
 #启动

./zkServer.sh status
#查看状态

输出：
JMX enabled by default

Using config: /usr/local/zookeeper-3.4.6/bin/../conf/zoo.cfg

Mode: standalone


2.安装Kafka
下载：

wget http://apache.fayea.com/kafka/0.8.2.1/kafka_2.10-0.8.2.1.tgz
解压：

tar -zxvf kafka_2.10-0.8.2.1.tgz -C /usr/local


启动kafka:

cd /usr/local/kafka_2.10-0.8.2.1/bin
 #进入启动文件

./kafka-server-start.sh   server.properties &
#启动服务挂在后台

3.开始使用
新建一个TOPIC：一句命令

./kafka-topics.sh --create --topic kafkatopic --replication-factor 1 --partitions 1 --zookeeper localhost:2181


<新建窗口>Kafka生产者启动：一句命令

./kafka-console-producer.sh --broker-list localhost:9092 --sync --topic kafkatopic


<新建窗口>Kafka消费者启动：一句命令

./kafka-console-consumer.sh --zookeeper localhost:2181 --topic kafkatopic --from-beginning


在生产端输入消息<回车>，消费端就能接受到数据了！