kafka_2.11-2.0.0 软件的准备

登陆官方网站进行下载2.0.0 版本。
准备服务器CentOs 7.3 版本

进行安装

tar -xvf kafka_2.11-2.0.0.tgz
启动自带的zookeeper
./zookeeper-server-start.sh …/config/server.properties&
启动kafka
./kafka-server-start.sh …/config/server.properties&

进行消息测试

创建一个为Alarm的消息类型，分区设置为1分区。
./kafka-topics.sh --create --zookeeper localhost:2181 --partitions 0 --topic Alarm
查看创建好的topic

./kafka-topics.sh --list --zookeeper localhost:2181
进行发送消息
./kafka-console-producer.sh --broker-list localhost:9092 --topic Alarm
进行接收消息
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Alarm

问题调试