kafka單機版安裝和啟動

上傳Kafka檔案包到Linux上

連結: ​​https://pan.baidu.com/s/1BmtknCyWIepjjKO2h2nOrA ​​提取碼: i8n8 複制這段内容後打開百度網盤手機App，操作更友善哦

下載下傳kafka_2.11-2.1.0.tgz到本地并且上傳到Linux指定目錄下後解壓:

[root@zjj101 soft]# tar -zxvf kafka_2.11-2.1.0.tgz      

建立Kafka日志檔案夾:

[root@zjj101 kafka_logs]# pwd      

修改配置檔案

#broker的全局唯一編号，不能重複
broker.id=0
#删除topic功能使能
delete.topic.enable=true
#kafka運作日志存放的路徑
log.dirs=/root/soft/run_logs/kafka_logs
# 連接配接zookeeper的位址,如果是叢集的話,就是:zjj101:2181,zjj102:2181,zjj103:2181 這樣的用逗号隔開的
zookeeper.connect=zjj101:2181      

添加環境變量

啟動Kafka

# 啟動指令
[root@zjj101 kafka_2.11-2.1.0]# $KAFKA_HOME/bin/kafka-server-start.sh -daemon  $KAFKA_HOME/config/server.properties
# 檢視Kafka是否啟動成功
[root@zjj101 kafka_2.11-2.1.0]# jps      

測試Kafka是否好用

# 建立topic,在任意目錄下都可以執行這個指令,因為前面有環境變量
[root@zjj101 kafka_2.11-2.1.0]# $KAFKA_HOME/bin/kafka-topics.sh --zookeeper zjj101:2181 --create --replication-factor 1 --partitions 1 --topic first
Created topic "first".

# 查詢目前kafka有哪些topic
[root@zjj101 kafka_2.11-2.1.0]# $KAFKA_HOME/bin/kafka-topics.sh --zookeeper zjj101:2181 --list
first
test01
[root@zjj101 kafka_2.11-2.1.0]#