centos7-kafka2.7.0部署

前置環境：java8+

1.從官方下載binary包到服務器 wget https://downloads.apache.org/kafka/2.7.0/kafka_2.13-2.7.0.tgz

2.根據官方手冊，解壓縮並進入目錄

 tar -xzf kafka_2.13-2.7.0.tgz

 cd kafka_2.13-2.7.0

3.如果配置較低，需要進入配置文件修改相應內存占用配置，zookeeper如下：

vim bin/zookeeper_server_start.sh

 

 

 kafka如下：

vim bin/kafka-server-start.sh

 

 

 

4.在kafka_2.13-2.7.0根目錄下創建兩個自定義的啟動腳本：

vim zookeeper_start.sh

nohup bin/zookeeper-server-start.sh config/zookeeper.properties >> zookeeper.out &

vim kafka_start.sh

nohup bin/kafka-server-start.sh config/server.properties >> kafka.out &

5.依次運行zookeeper、kafka的sh

6.按照官方文檔，測試是否可以執行測試腳本如下

創建topic
$ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

執行生產者
$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
>This is my first event
>This is my second event

執行消費者
$ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
This is my first event
This is my second event

至此，kafka centos的基礎部署完成