<output id="qn6qe"></output>

    1. <output id="qn6qe"><tt id="qn6qe"></tt></output>
    2. <strike id="qn6qe"></strike>

      亚洲 日本 欧洲 欧美 视频,日韩中文字幕有码av,一本一道av中文字幕无码,国产线播放免费人成视频播放,人妻少妇偷人无码视频,日夜啪啪一区二区三区,国产尤物精品自在拍视频首页,久热这里只有精品12

      Centos8安裝kafka【單機版】

      kafka自2.8.0版本開始,不再將zookeeper作為必需組件,本文的實驗環境為kafka2.4.0,因此在安裝kafka之前,首先需要安裝zookeeper。

      1. 下載kafka與zookeeper

      kafka下載地址
      需要下載與kafka版本對應的zookeeper版本,進入kafka安裝包的libs目錄,查看對應zookeeper依賴。

      cd /usr/local/src/
      wget https://archive.apache.org/dist/kafka/2.4.0/kafka_2.12-2.4.0.tgz
      tar -zxvf kafka_2.12-2.4.0.tgz
      # 查看版本:
      cd kafka_2.12-2.4.0/libs
      ls | grep zookeeper
      

      image
      可以看到,2.4.0版本的kafka依賴的zookeeper的版本為3.5.6。
      image
      zookeeper下載鏡像地址:https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/

      2. 安裝zookeeper

      2.1 解壓zookeeper

      tar -zxvf apache-zookeeper-3.5.6-bin.tar.gz
      

      2.2 修改配置文件

      cd /usr/local/src/apache-zookeeper-3.5.6-bin/conf
      cp zoo_sample.cfg zoo.cfg
      

      2.3 啟動測試

      cd /usr/local/src/apache-zookeeper-3.5.6-bin/bin
      # 啟動
      ./zkServer.sh start
      # 停止
      ./zkServer.sh stop
      

      image
      2.4 將zookeeper啟動命令加入環境變量

      vi /etc/profile
      export PATH=$PATH:/usr/local/src/apache-zookeeper-3.5.6-bin/bin
      source /etc/profile
      

      3. 配置kafka

      vi /usr/local/src/kafka_2.12-2.4.0/config/server.properties
      //如果只允許本地訪問 則用localhost,如果需要外網可以訪問則用服務器地址,即安裝kafka的主機ip,我是在虛擬機上安裝,故填虛擬機IP:192.168.29.128
      listeners=PLAINTEXT://192.168.29.128:9092
      
      //dataDir是數據存放位置,默認是/tmp/kafka-logs
      # dataDir=xxxx
      //這個是刪除topic時才用得到的,如果不想刪除topic,可以不加
      # delete.topic.enable=true
      

      4. 啟動kafka

      進入bin目錄
      前臺啟動
      kafka-server-start.sh ../config/server.properties
      后臺啟動
      nohup kafka-server-start.sh ../config/server.properties >> /dev/null &
      

      5. 創建topic

      進入bin目錄

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

      --zookeeper后面的參數需要與server.properties配置中的一致,server.properties在config目錄下,見下圖
      image

      6. 發送接收消息

      以下操作均在bin目錄下進行
      6.1 創建生產者

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

      image
      6.2 創建消費者

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

      image
      6.3 為kafka配置系統環境變量

      vi /etc/profile
      export PATH=$PATH:/usr/local/src/kafka_2.12-2.4.0/bin
      source /etc/profile
      

      補充

      kafka的一些操作

      kafka主題
      kafka-topics.sh 
      生產者
      kafka-console-producer.sh
      消費者
      kafka-console-consumer.sh
      

      topic的一些操作

      查看列表
      kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
      
      創建topic
      kafka-topics.sh --create --replication-factor 1 --partitions 1 --topic test --zookeeper localhost:2181
      
      查看某個topic
      kafka-topics.sh --zookeeper localhost:2181 --describe --topic test
      
      刪除topic(分兩步)
      (第一步)
      kafka-topics.sh  --delete --zookeeper localhost:2181 --topic test
      (第二步 找到top存放位置:server.properties中dataDir)
      cd /tmp/kafka-logs
      刪除 test-0(如果kafka配置文件中delete.topic.enable=true沒有設置的話,需要手動刪除目錄)
      rm -rf test-0
      

      參考文章:
      https://blog.csdn.net/qq_34892981/article/details/110668529
      推薦一個kafka的可視化工具,地址如下:
      http://www.rzrgm.cn/miracle-luna/p/11299345.html

       
      分類: Linux
      posted @ 2025-05-29 09:00  人生苦短,知足常樂!  閱讀(84)  評論(0)    收藏  舉報
      主站蜘蛛池模板: 国产久免费热视频在线观看| 久久久www成人免费精品| 国产中文字幕一区二区| 无码丰满人妻熟妇区| 久久天天躁夜夜躁狠狠85| 乱人伦中文字幕成人网站在线| 四虎永久在线精品免费播放| 狠狠色噜噜狠狠狠狠2021| 亚洲人成网站在线在线观看| 疯狂做受XXXX高潮国产| 男人扒开女人内裤强吻桶进去| A毛片终身免费观看网站| 亚洲中文字幕有综合久久| 国产精品一区二区国产馆| 国产妇女馒头高清泬20p多毛| 欧美性受xxxx黑人猛交| 狠狠干| 中文字幕无线码在线观看| 久久精品伊人狠狠大香网| 无码日韩精品一区二区三区免费| 四虎国产精品免费久久| 亚洲精中文字幕二区三区| 狠狠躁夜夜躁人人爽天天古典| 国产日产欧美最新| 精品国产亚洲区久久露脸| 库尔勒市| 国产99视频精品免费视频76| 日韩一区二区三区亚洲一| 好硬好湿好爽好深视频| 无码人妻出轨黑人中文字幕| 深夜精品免费在线观看| 免费无码毛片一区二三区| 免费人成在线视频无码| 亚洲av永久无码精品网站| 亚洲色精品vr一区区三区| 国产亚洲欧美精品久久久| 夜夜躁狠狠躁2021| 自偷自拍亚洲综合精品| 夜夜偷天天爽夜夜爱| 久久精品波多野结衣| 亚洲尤码不卡av麻豆|