kafka之快速啟動

2021-09-07 19:33:58 字數 1335 閱讀 5342

topic 主題 是kafka集群中用於儲存某一類 或者某一種資料。主題的資料只能新增

broker 集群中的每乙個分機 都是乙個broker 相當於kafka集群的節點

consumer 消費者 用來從kafka 集群中讀取訊息

producer 生產者 用於從kafka 集群中傳送訊息

streams 流 用於對實時資料的處理

partition 分割槽 每乙個topic 可以分為多個區 提高併發,每個分割槽資料不會重複

replication 副本 用於提高 資訊保安 當儲存某個分割槽的節點宕機時候,該broker 的資料將會丟失,為了保障資料的安全性 分割槽時候應該建立副本

安裝kafka

安裝方式有兩種一種是 tar.gz的解壓版 ,還有乙個是wget方式安裝

啟動服務

首先 kafka 依賴 zookeeper 要先啟動zookeeper 服務才行。

啟動命令

bin/zookeeper-server-start.sh config/zookeeper.properties
啟動kafka

bin/kafka-server-start.sh -daemon config/server.properties
常用命令

建立乙個topic (test)

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
檢視自己所建立的所有topic

bin/kafka-topics.sh --list --zookeeper localhost:2181
傳送訊息 向test 主題傳送資訊

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
消費訊息 檢視test 主題的資訊

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

Kafka補充及啟動kafka

補充 kafka中可以有多個broker,我們理解時可以把broker當做乙個新華書店理解 broker中可以有多個topic,topic是邏輯分割槽及邏輯存在的主題,不儲存資料 topic中可以有多個partition 分割槽 partition是真正存放資料的地方,乙個partition是乙個強...

kafka啟動命令 Kafka入門

kafka是乙個高效能分布式訊息系統,今天就簡單介紹下基礎入門吧。tar xzf kafka 2.12 2.2.0.tgz cd kafka 2.12 2.2.0二 啟動伺服器kafka使用zookeeper,所以我們要先啟動zookeeper,可以使用安裝檔案裡面的啟動命令啟動乙個單節點的zook...

kafka啟動命令

啟動 bin kafka server start.sh daemon config server.properties 建立主題 kafka topics.sh zookeeper s202 2181 topic calllog create replication factor 3 partit...