Kafka系列文章之kafka環境搭建

現在最新的版本是2.1.1

將安裝包解壓到指定位置

3.1.修改kafka_home/config/zookeeper.properties，將datadir 修改為自己的data資料夾

3.2.修改kafka_home/config/server.properties，將datadir 修改為自己的data資料夾

4.1.啟動zookeeper，cd到kafka_home/bin/windows/目錄下，執行以下命令：zookeeper-server-start.bat [/conf/zookeeper.properties]

4.2.啟動kafka，cd到/bin/windows/目錄下，執行以下命令：kafka-server-start.bat [/conf/server.properties]

4.3.linux 啟動zookeeper：cd到kafka_home/bin/, 執行以下命令：zookeeper-server-start.sh [/conf/zookeeper.properties]"

4.4.linux 啟動kafka：cd到kafka_home/bin/, 執行以下命令：kafka-server-start.sh [/conf/zookeeper.properties]"

cd到 /bin/windows/, 執行以下命令：kafka-topics.bat --zookeeper localhost:2181 --create --topictest_kafka_topic--partitions 3 --replication-factor 1

linux：/bin/, 執行以下命令：./kafka-topics.sh --zookeeper localhost:2181 --create --topictest_kafka_topic--partitions 3 --replication-factor 1"

6.1.建立producer

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

輸入hello,kafka

6.2.建立consumer

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

將會輸出hello,kafka

至此kafka的環境搭建完畢，下一節將手把手寫乙個kafka的程式。