kafka搭建

单机版

安装java环境：

yum install java -y

下载kafka包：

http://kafka.apache.org/downloads

启动zookeeper：kafka中自带的zookeeper

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

启动kafka：

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

创建topic：

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

查看topic：

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test1

打开消费者：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1 --from-beginning

打开生产者：

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

然后输入内容在消费者那边看是否有内容输出，如果有则正常。