软件环境

CentOS6.5

JDK1.8

kafka_2.10-0.10.0.0

 

安装Java Jdk

 

省略...

 

下载安装文件： http://kafka.apache.org/downloads.html

解压下载的kafka

 

tar -zxvf kafka_xxx.tgz

cd kafka_xxx

 

安装Zookeeper

 

启动zk有两种方式，第一种是使用kafka自带的一个zk。

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

 

另一种是使用其它的zookeeper，可以位于本机也可以位于其它地址。

这种情况需要修改config下面的sercer.properties里面的zookeeper地址

例如zookeeper.connect=ip:2181

安装省略

 

防火墙开启默认的端口2181和9092 

 

启动kafka

进入kafka_xxx目录

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

 

创建topic

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

创建一个名为mytopic的topic，只有一个副本，一个分区。

 

通过list命令查看刚刚创建的topic

bin/kafka-topics.sh -list -zookeeper localhost:2181

 

启动producer

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic

启动之后就可以发送消息了,随便输入 按回车

按Ctrl+C退出发送消息

 

启动consumer

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

启动consumer之后就可以在console中看到producer发送的消息了

也可以开启两个终端，一个发送消息端，一个接受消息端 来进行测试。

 

kafka开机自动启动

未完待续