Kafka系列文章之kafka环境搭建

1.下载kafka

http://kafka.apache.org/downloads，现在最新的版本是2.1.1

2.解压

将安装包解压到指定位置

3.修改配置文件

3.1.修改kafka_home/config/zookeeper.properties，将dataDir 修改为自己的data文件夹

3.2.修改kafka_home/config/server.properties，将dataDir 修改为自己的data文件夹

4.启动kafka

4.1.启动zookeeper，cd到kafka_home/bin/windows/目录下，执行以下命令：zookeeper-server-start.bat [<kafka_home>/conf/zookeeper.properties]

4.2.启动kafka，cd到<kafka_home>/bin/windows/目录下，执行以下命令：kafka-server-start.bat [<kafka_home>/conf/server.properties]

4.3.Linux 启动zookeeper：cd到kafka_home/bin/, 执行以下命令：zookeeper-server-start.sh [<kafka_home>/conf/zookeeper.properties]"

4.4.Linux 启动kafka：cd到kafka_home/bin/, 执行以下命令：kafka-server-start.sh [<kafka_home>/conf/zookeeper.properties]"

5.创建kafka主题，主题名称叫test_kafka_topic

cd到 <kafka_home>/bin/windows/, 执行以下命令：kafka-topics.bat --zookeeper localhost:2181 --create --topic test_kafka_topic --partitions 3 --replication-factor 1

Linux：<kafka_home>/bin/,  执行以下命令：./kafka-topics.sh --zookeeper localhost:2181 --create --topic test_kafka_topic --partitions 3 --replication-factor 1"

6.测试kafka

6.1.创建producer

cd到kafka_home/bin/windows/, 执行： kafka-console-producer.bat --broker-list localhost:9092 --topic test_kafka_topic 

输入hello,kafka

6.2.创建consumer

cd到kafka_home/bin/windows/,执行：kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test_kafka_topic 

将会输出hello,kafka

至此kafka的环境搭建完毕，下一节将手把手写一个kafka的程序。