topic 主題 是kafka集群中用於儲存某一類 或者某一種資料。主題的資料只能新增
broker 集群中的每乙個分機 都是乙個broker 相當於kafka集群的節點
consumer 消費者 用來從kafka 集群中讀取訊息
producer 生產者 用於從kafka 集群中傳送訊息
streams 流 用於對實時資料的處理
partition 分割槽 每乙個topic 可以分為多個區 提高併發,每個分割槽資料不會重複
replication 副本 用於提高 資訊保安 當儲存某個分割槽的節點宕機時候,該broker 的資料將會丟失,為了保障資料的安全性 分割槽時候應該建立副本
安裝kafka
安裝方式有兩種一種是 tar.gz的解壓版 ,還有乙個是wget方式安裝
啟動服務
首先 kafka 依賴 zookeeper 要先啟動zookeeper 服務才行。
啟動命令
啟動kafkabin/zookeeper-server-start.sh config/zookeeper.properties
常用命令bin/kafka-server-start.sh -daemon config/server.properties
建立乙個topic (test)
檢視自己所建立的所有topicbin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
傳送訊息 向test 主題傳送資訊bin/kafka-topics.sh --list --zookeeper localhost:2181
消費訊息 檢視test 主題的資訊bin/kafka-console-producer.sh --broker-list localhost:9092 --topic 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...