Linux下安装配置Kafka

下载
cd /usr/local/src
wget https://archive.apache.org/dist/kafka/0.10.0.0/kafka_2.11-0.10.0.0.tgz
安装
tar -xzvf kafka_2.11-0.10.0.0.tgz

配置
cd kafka_2.11-0.10.0.0/conf

vim zookeeper.properties

vim server.properties

启动
cd bin
./kafka-server-start.sh ../config/server.properties

后台启动
./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &

停止服务
./kafka-server-stop.sh

创建topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
(创建了"test" topic)

列出topic列表
./kafka-topics.sh --list --zookeeper localhost:2181

生产消息
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
输入消息···

消费消息
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

注意
kafka版本对于jdk版本有要求
安装kafka_2.11-1.0.0遇到以下问题
Unsupported major.minor version 52.0

上网查阅资料：
J2SE 8 = 52
J2SE 7 = 51
J2SE 6.0 = 50
J2SE 5.0 = 49

使用java -version查看自己jdk版本为1.7
后改用kafka_2.11-0.10.0.0