溫馨提示×

centos中kafka配置步驟是什么

小樊
47
2025-05-13 00:55:31
欄目: 智能運維

在CentOS上配置Kafka的步驟如下:

  1. 安裝JDK: 首先,需要安裝JDK??梢允褂靡韵旅畎惭bJDK 1.8:

    sudo yum install java-1.8.0-openjdk-devel -y
    

    安裝完成后,驗證JDK是否安裝成功:

    java -version
    
  2. 下載并解壓Kafka: 從Apache Kafka官網下載所需的Kafka版本,然后解壓到指定目錄。例如,下載Kafka 3.5.2版本:

    wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
    tar -zxvf kafka_2.12-3.5.2.tgz -C /usr/local/kafka
    cd /usr/local/kafka
    
  3. 配置Zookeeper: Kafka依賴Zookeeper,因此需要先配置Zookeeper。編輯config/zookeeper.properties文件,設置數據目錄和客戶端端口等參數:

    dataDir /usr/local/kafka/zookeeper
    clientPort 2181
    

    然后啟動Zookeeper服務:

    nohup /usr/local/kafka/bin/zookeeper-server-start.sh config/zookeeper.properties &
    
  4. 配置Kafka: 編輯Kafka的config/server.properties文件,設置以下關鍵參數:

    broker.id=0
    listeners=PLAINTEXT://your_server_ip:9092
    advertised.listeners=PLAINTEXT://your_server_ip:9092
    log.dirs=/usr/local/kafka/kafka-logs
    zookeeper.connect=localhost:2181
    
  5. 啟動Kafka服務: 使用以下命令啟動Kafka服務:

    nohup /usr/local/kafka/bin/kafka-server-start.sh config/server.properties &
    
  6. 驗證Kafka配置: 創建一個測試主題并驗證Kafka是否正常工作:

    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    bin/kafka-topics.sh --list --zookeeper localhost:2181
    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
    

請注意,這里的your_server_ip需要替換為你的服務器實際IP地址。

0
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女