啟動kafka服務
kafka-server-start.sh ../config/server.properties &
ps -ef | grep kafka檢視,觀察到zookeeper和kafka服務已啟動
建立乙個叫」test1234」的topic,它只有乙個分割槽,乙個副本:
kafka
-topics.sh
--create--
zookeeper
localhost:2181--
replication
-factor1-
-partitions1-
-topic
test1234
可以用list檢視建立的topic
kafka
-topics.sh
--list--
zookeeper
localhost:2181
傳送訊息。執行producer並在控制台中輸一些訊息,這些訊息將被傳送到服務端
kafka-console
-producer
.sh --broker-list localhost:9092
--topic test1234
在另乙個終端開啟consumer,可以讀取到剛才發出的訊息並輸出。
kafka
-console
-consumer.sh
--zookeeper
localhost:2181--
topic
test1234--
from
-beginning
centos7單機安裝kafka
基礎要求作業系統 centos 7x 64位 kafka版本 kafka 2.11 0.8.2.1 提取碼 ns3c 1 關閉selinux 開放防火牆9092埠 root wzy x vi etc selinux config root wzy x tail 2 etc selinux confi...
CentOS7下Kafka安裝 黃海的技術空間
使用kafka自帶的zookeeper進行安裝 可參看kafka自帶的說明檔案 為kafka和zookeep配置centos下的服務 為kafka和zookeep配置firwalld相關的檔案 前提安裝環境為centos7.x,官網 最新版的kafka,解壓至 opt kafka中 可以建立乙個指向...
Centos7下kafka集群搭建
1.kafka以topic來進行訊息管理,每個topic包含多個partition,每個partition對應乙個邏輯log,有多個segment組成。2.每個segment中儲存多條訊息 見下圖 訊息id由其邏輯位置決定,即從訊息id可直接定位到訊息的儲存位置,避免id到位置的額外對映。3.每個p...