Kafka系列1--入门环境搭建

1）操作系统：

cat /etc/redhat-release 

CentOS Linux release 7.2.1511 (Core) 

2）下载kafka并解压到/opt目录下
http://kafka.apache.org/downloads.html
Scala 2.11  - kafka_2.11-0.10.0.0.tgz (asc, md5)

3）启动zookeeper

./bin/zookeeper-server-start.sh ./config/zookeeper.properties

启动成功，查看绑定的端口（默认为2181）：

......

INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory)

......

4）启动kafka

./bin/kafka-server-start.sh ./config/server.properties

启动成功，查看绑定的端口（默认为9092）：

......

INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor)

......

5）查看启动的进程

jps

117945 QuorumPeerMain

118747 Jps

118170 Kafka

6）新建和查看topic

新建一个名字叫test的topic：

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 127.0.0.1:2181