CentOS 7下安裝Kafka單機版

2021-08-18 08:35:41 字數 890 閱讀 7942

啟動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...