在Linux上安裝Kafka的步驟如下:
sudo apt install openjdk-8-jdksudo yum install java-1.8.0-openjdkjava -version命令確認JDK安裝成功。tar -zxvf命令解壓下載的Kafka壓縮包。例如:tar -zxvf kafka_2.13-3.2.0.tgzmv kafka_2.13-3.2.0.tgz kafka進入配置目錄:cd /usr/local/kafka/config
編輯server.properties文件:
vim)打開server.properties文件。broker.id:設置為唯一標識符,例如1。log.dirs:設置Kafka日志存儲目錄,例如/tmp/kafka-logs。zookeeper.connect:設置Zookeeper連接地址,例如zk_ip:2181。listeners:設置Kafka監聽地址,例如PLAINTEXT://your_server_ip:9092。log.retention.hours:設置日志保留時間,例如168(表示一周)。delete.topic.enable:設置為true以允許刪除topic。nohup bin/zookeeper-server-start.sh config/zookeeper.properties &nohup bin/kafka-server-start.sh config/server.properties &ps -ef | grep zookeeper命令查看Zookeeper進程。bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server your_server_ip:9092,然后輸入消息測試。bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server your_server_ip:9092,訂閱并消費消息。以上步驟為Kafka在Linux上的基本安裝流程,具體操作可能會因Linux發行版和Kafka版本的不同而略有差異。