kafka 單機環境kafka搭建

2021-10-04 18:40:14 字數 1092 閱讀 1745

目錄

一、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...