先贴个官网的教程http://kafka.apache.org/quickstart 官方教程中提到的我就略过了，我讲点不一样的。

        我用的CentOS的图形化界面，建了个Qbit文件夹然后把官网下载的压缩包解压到里面。

然后这就算部署完了,下面要启动了,进入CLI界面(以下命令都需要进kafka的安装目录执行,对我而言在CLI打开后执行cd Qbit/kafka*就行了)

一,执行bin/zookeeper-server-start.sh config/zookeeper.properties启动zookeeper,然后会停在绑定端口

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

这并不是卡了(害得我还在网上找了一半天解决方案....),另外上面的命令在bin目录外边运行,如果进了bin目录就意味着后面配置文件的相对路径也变了(我当时进了bin执行结果找不到配置文件)

二,再起一个CLI界面到kafka目录,用su提权(直接用sudo居然不行...),否则会被拒绝写日志,执行

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

启动kafka

三,然后创建一个topic,再来一个CLI

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

网上教程用的长中划线,我这里报错,换成两个短中划线后OK

(可以用bin/kafka-topics.sh –list –zookeeper localhost:2181)看下是否成功

四,开始发消息,再来个CLI执行

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

然后光标会停在下一行的行首,这是提示输入要发送的信息(我以为又卡了...),顺便输入一些敲回车,然后发了,可以接着输下一条信息,因为现在还没有消息的消费者,所以看不到其他效果

五,接收消息,来第四个CLI,执行

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

就可以看到刚发的消息了,然后再producer的CLI界面继续输入消息,回车后consumer这面的CLI就会显示了