阿里雲安裝Kafka並配置外網訪問

本機安裝

# 檢測java
java -version

# 如果沒有則安裝
yum -y install java

# 下載
wget http://mirrors.hust.edu.cn/apache/kafka/2.6.0/kafka_2.13-2.6.0.tgz

# 解壓
 tar -xvf kafka_2.13-2.6.0.tgz

# 修改文件夾名
mv kafka_2.13-2.6.0 kafka

# 打開~/.bash_profile文件
vim ~/.bash_profile

# 在末尾添加環境變量（此處我的kafka在root目錄下）
export PATH=/root/kafka/bin:$PATH 

# 保存並關閉文件，source一下
source ~/.bash_profile

# 打開任意路徑執行以下命令驗證
kafka-topic.sh

# 轉到kafka目錄，新建兩個文件夾
cd /root/kafka/ && mkdir data && mkdir data/zookeeper

# 在kafka目錄下，編輯zookeeper配置文件
vim config/zookeeper.properties

# 將dataDir=/tmp/zookeeper修改為剛才新建的文件夾
dataDir=/root/kafka/data/zookeeper

# 啟動zookeeper （有日志INFO binding to port 0.0.0.0/0.0.0.0:2181 表示啟動成功）
zookeeper-server-start.sh config/zookeeper.properties

# 在kafka目錄下執行
mkdir data/kafka

# 在kafka目錄下，編輯server配置文件
vim config/server.properties

# log.dirs=/tmp/kafka-logs改為
log.dirs=/root/kafka/data/kafka

# 啟動kafka （有日志INFO [KafkaServer id=0] started 表示啟動成功）
kafka-server-start.sh config/server.properties

開啟外網訪問

# 1. 阿里雲ECS添加安全組

# 2. 修改config/server.properties文件，添加如下
listeners=PLAINTEXT://<內網IP>:9092
advertised.listeners=PLAINTEXT://<公網IP>:9092