Ubuntu Kafka配置新手指南

在Ubuntu上配置Apache Kafka的步驟如下：

1. 安裝Java環境

首先，需要安裝Java開發工具包（JDK）?？梢允褂靡韵旅畎惭bJDK 8：

sudo apt update
sudo apt install openjdk-8-jdk

安裝完成后，驗證Java是否正確安裝：

java -version

2. 安裝Zookeeper

Kafka依賴于Zookeeper進行集群管理和元數據存儲。以下是安裝和啟動Zookeeper的步驟：

• 下載Zookeeper：

  wget https://archive.apache.org/dist/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
  

• 解壓Zookeeper：

  tar xvf zookeeper-3.4.6.tar.gz
  

• 移動Zookeeper到/usr/local：

  sudo mv zookeeper-3.4.6 /usr/local/zookeeper
  

• 配置Zookeeper：

  編輯/usr/local/zookeeper/conf/zoo.cfg文件，添加或修改以下配置：

  tickTime=2000
  dataDir=/var/lib/zookeeper
  clientPort=2181
  

• 啟動Zookeeper：

  sudo /usr/local/zookeeper/bin/zkServer.sh start
  

• 驗證Zookeeper是否啟動成功：

  sudo netstat -nap | grep 2181
  

3. 安裝Kafka

• 下載Kafka：

  從Apache Kafka官網下載適合Ubuntu版本的Kafka安裝包。例如，下載Kafka 3.5.2版本：

  wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
  

• 解壓Kafka：

  tar -xzvf kafka_2.12-3.5.2.tgz
  

• 移動Kafka到/usr/local：

  sudo mv kafka_2.12-3.5.2 /usr/local/kafka
  

4. 配置Kafka

• 啟動Kafka服務：

  進入Kafka的bin目錄，啟動Kafka服務器：

  cd /usr/local/kafka/bin
  ./kafka-server-start.sh ../config/server.properties
  

• 驗證Kafka是否啟動成功：

  使用以下命令查看Kafka進程：

  ps aux | grep kafka
  

• 創建Topic：

  創建一個新的Topic用于測試：

  ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
  

• 發送和消費消息：

  使用kafka-console-producer.sh發送消息：

  ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
  

  使用kafka-console-consumer.sh消費消息：

  ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
  

以上步驟是在Ubuntu上配置Kafka的基本流程。對于更復雜的集群配置，可能需要進一步調整Kafka和Zookeeper的配置文件，以及設置多個Broker和相應的Zookeeper實例。此外，Kafka的版本選擇也非常重要，不同版本之間可能存在API和命令參數的差異，需要根據實際情況進行選擇和調整。