首頁 系統教程 Linux 在CentOS7上安裝Kafka的步驟詳解

在CentOS7上安裝Kafka的步驟詳解

Dec 29, 2023 pm 05:19 PM
centos7 kafka

簡介

Kafka 是一種高吞吐的分散式發布訂閱訊息系統,能夠取代傳統的訊息佇列用於解耦合資料處理,快取未處理訊息等,同時具有更高的吞吐率,支援分區、多重副本、冗餘,因此被廣泛用於大規模訊息資料處理應用

Kafka 支援Java 及多種其它語言用戶端,可與Hadoop、Storm、Spark等其它大數據工具結合使用。

本教學主要介紹Kafka 在Centos 7上的安裝和使用,包括功能驗證和叢集的簡單配置。

安裝JDK

Kafka 使用Zookeeper 來保存相關設定訊息,Kafka及Zookeeper 依賴Java 運作環境,從oracle網站下載JDK 安裝包,解壓縮安裝:

$tar zxvf jdk-8u65-linux-x64.tar.gz
$mv jdk1.8.0_65 java
登入後複製

設定Java 環境變數:

JAVA_HOME=/opt/java
PATH=$PATH:$JAVA_HOME/bin
export JAVA_HOME PATH
登入後複製

也可以選擇yum install安裝,對應設定環境變數。

安裝Kafka

從官網下載Kafka 安裝包,解壓縮安裝: 官網網址:https://www.php.cn/link/dcf531edc9b229acfe0f4b87e1e278dd

#
tar zxvf kafka_2.11-0.8.2.2.tgz
mv kafka_2.11-0.8.2.2 kafka
cd kafka
登入後複製

功能驗證

1.啟動Zookeeper 使用安裝套件中的腳本啟動單節點Zookeeper 實例:

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
登入後複製

2.啟動Kafka 服務 使用kafka-server-start.sh 啟動kafka 服務:

bin/kafka-server-start.sh config/server.properties
登入後複製

3.建立topic 使用kafka-topics.sh 建立單一分區單一副本的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
登入後複製

4.產生訊息 使用kafka-console-producer.sh 傳送訊息:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 
Hello world!
登入後複製

5.消費訊息 使用kafka-console-consumer.sh 接收訊息並在終端機上列印:

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
登入後複製

producer產生的訊息和consumer消費的訊息是同步的。

在CentOS7上安裝Kafka的步驟詳解

#

以上是在CentOS7上安裝Kafka的步驟詳解的詳細內容。更多資訊請關注PHP中文網其他相關文章!

本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

熱門話題

Java教學
1662
14
CakePHP 教程
1418
52
Laravel 教程
1311
25
PHP教程
1261
29
C# 教程
1234
24
CentOS7各版本鏡像下載地址及版本說明(包括Everything版) CentOS7各版本鏡像下載地址及版本說明(包括Everything版) Feb 29, 2024 am 09:20 AM

載CentOS-7.0-1406的時候,有很多可選則的版本,對於普通用戶來說,不知道選擇哪個好,下面做一下簡單介紹:(1)CentOS-xxxx-LiveCD.ios和CentOS-xxxx- bin-DVD.iso有什麼差別?前者只有700M,後者有3.8G。其差異不僅在大小上,其更本質的差異是,CentOS-xxxx-LiveCD.ios只能載入到記憶體裡運行,不能安裝。 CentOS-xxx-bin-DVD1.iso才可以安裝到硬碟上。 (2)CentOS-xxx-bin-DVD1.iso,Ce

CentOS 7 緊急修復模式的進入步驟 CentOS 7 緊急修復模式的進入步驟 Jan 13, 2024 am 09:36 AM

打開centos7頁面出現:welcometoemergencymode! afterloggingin,type“journalctl-xb”toviewsystemlogs,“systemctlreboot”toreboot,“systemctldefault”totryagaintobootintodefaultmode。 giverootpasswordformaintenance(??Control-D???):解決方法:執行r

如何在CentOS 7中存取並清理/tmp目錄中的垃圾檔案? 如何在CentOS 7中存取並清理/tmp目錄中的垃圾檔案? Dec 27, 2023 pm 09:10 PM

centos7系統中tmp目錄下有很多垃圾,想要清除垃圾,該怎麼清除呢?下面我們就來看看詳細的教學。查看tmp檔案目錄下檔案列表,執行指令cdtmp/切換到tmp目前檔案目錄,執行ll指令,查看目前目錄下檔列表。如下圖所示。使用rm刪除檔案指令,需要注意的是rm指令是將檔案永遠從系統中刪除,因此建議在使用rm指令時,最好是在刪除檔案前給予提示。使用指令rm-i檔名,等用戶確認刪除(y)或跳過刪除(n),系統進行對應的操作。如下圖所示。

centos7如何設定密碼規則?centos7設定密碼規則的方法 centos7如何設定密碼規則?centos7設定密碼規則的方法 Jan 07, 2024 pm 01:17 PM

出於安全考慮設定密碼規則設定密碼到期的天數。使用者必須在天內更改密碼。此設定僅影響建立用戶,而不會影響現有用戶。如果設定為現有用戶,請執行指令「chage-M(days)(user)」。 PASS_MAX_DAYS60#密碼到期時間PASS_MIN_DAYS3#初始密碼更改時間PASS_MIN_LEN8#密碼最小長度PASS_WARN_AGE7#密碼過期提示時間重複密碼限制使用[root@linuxprobe~]#vi/etc/pam.d/system-auth#nearline15:

centos7下解壓縮檔案指令(zip)詳解 centos7下解壓縮檔案指令(zip)詳解 Jan 07, 2024 pm 06:30 PM

1.壓縮資料夾為zip檔[root@cgls]#zip-rmydata.zipmydata2.把mydata.zip解壓縮到mydatabak目錄裡面[root@cgls]#unzipmydata.zip-dmydatabak3.mydata01資料夾和mydata02.txt mydata.zip[root@cgls]#zipmydata.zipmydata01mydata02.txt4.直接解壓縮mydata.zipmydata.zipmydata01mydata02.txt4.直接解壓縮mydata.zip檔[root@cgls]#unzipmydata.zip5.查看myd

CENTOS7下如何安裝mbstring擴充? CENTOS7下如何安裝mbstring擴充? Jan 06, 2024 pm 09:59 PM

1.UncaughtError:Calltoundefinedfunctionmb_strlen();出現如上錯誤時,說明我們沒裝上mbstring擴展;2.進入PHP安裝目錄cd/temp001/php-7.1.0/ext/mbstring3.啟動phpize(/usr/local/bin /phpize或/usr/local/php7-abel001/bin/phpize)指令來安裝php擴充4../configure--with-php-config=/usr/local/php7-abel

五種選擇的可視化工具,用於探索Kafka 五種選擇的可視化工具,用於探索Kafka Feb 01, 2024 am 08:03 AM

Kafka視覺化工具的五種選擇ApacheKafka是一個分散式串流處理平台,能夠處理大量即時資料。它廣泛用於建立即時資料管道、訊息佇列和事件驅動的應用程式。 Kafka的視覺化工具可以幫助使用者監控和管理Kafka集群,並且更好地理解Kafka資料流。以下是對五種流行的Kafka視覺化工具的介紹:ConfluentControlCenterConfluent

kafka視覺化工具比較分析:如何選擇最適合的工具? kafka視覺化工具比較分析:如何選擇最適合的工具? Jan 05, 2024 pm 12:15 PM

如何選擇合適的Kafka視覺化工具?五款工具比較分析引言:Kafka是一種高效能、高吞吐量的分散式訊息佇列系統,被廣泛應用於大數據領域。隨著Kafka的流行,越來越多的企業和開發者需要一個視覺化工具來方便地監控和管理Kafka叢集。本文將介紹五款常用的Kafka視覺化工具,並比較它們的特色和功能,幫助讀者選擇適合自己需求的工具。一、KafkaManager

See all articles