目錄
一、kafka搭建方法:
二、kafka常用命令行:
1.topic建立:
2.命令列生產者
3.命令列消費者
step1:解壓kafka
tar -zxvf kafka_2.13-2.4.0.tgz
step2:啟動zookeeper:
bin/zookeeper-server-start.sh ./config/zookeeper.properties
step3:啟動kafka:
配置檔案中 listeners=plaintext://host_ip:9092為外部可見狀態
bin/kafka-server-start.sh ./config/server.properties
方法1(不建議):自動建立
可以設定將config/server.properties配置檔案中配置了auto.create.topics.enable引數為true
那麼當生產者向乙個尚未建立的topic傳送訊息時,會自動建立乙個num.partitions(預設值為1)個分割槽和default.replication.factor(預設值為1)個副本的對應topic
方法2:手動建立
通過kafka-topics.sh指令碼來建立乙個名為topic-test1並且副本數為2、分割槽數為4的topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic topic-test --replication-factor 2 --partitions 4
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic_test
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_test
Kafka 單機kafka部署
1 上傳部署包 kafka 2.11 0.11.0.0.tgz 放到 opt software 2 解壓 tar zxvf kafka 2.11 0.11.0.0.tgz c opt module 3 切換目錄 opt module kafka 2.11 0.11.0.0 conf 4 修改配置 v...
Kafka單機Windows環境搭建
kafka單機windows環境搭建 1,安裝jdk1.8 安裝目錄不能有中文空格 解壓到d zookeeper 3.4.11之後,在conf目錄下面重新命名zoo sample.cfg為zoo.cfg,在zoo.cfg修改如下內容 datadir d zookeeper 3.4.11 data d...
Kafka單機環境的部署
前面說過kafka集群環境的部署,現在主要說一下在本地測試中kafka單機環境的部署,和前面一樣首先保證zookeeper服務的正常執行,然後解壓並釋放kafka安裝包,並放到指定位置 tar xvzf kafka 2.9.2 0.8.2.2.tar.gz mkdir usr kafka mv ka...