国产无码综合区,色欲AV无码国产永久播放,无码天堂亚洲国产AV,国产日韩欧美女同一区二区

中間件： Kafka安裝部署

2年前作者：一點博客分類：Toy博客閱讀(22)違法舉報

這篇具有很好參考價值的文章主要介紹了中間件： Kafka安裝部署。希望對大家有所幫助。如果存在錯誤或未考慮完全的地方，請大家不吝賜教，您也可以點擊"舉報違法"按鈕提交疑問。

單機部署

下載二進制包

cd /opt/soft/archive
wget http://archive.apache.org/dist/kafka/3.2.0/kafka_2.12-3.2.0.tgz
tar -zxf kafka_2.12-3.2.0.tgz -C ../
cd ../kafka_2.12-3.2.0

修改配置

vim config/server.properties

advertised.listeners=PLAINTEXT://39.105.11.50:9092

啟動

sh bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
sh bin/kafka-server-start.sh  -daemon config/server.properties

集群部署

按照單機部署方式啟動多個Zookeeper與broker節(jié)點。
修改config/server.properties配置：文章來源地址http://www.zghlxwxcb.cn/news/detail-658848.html

broker.id 每個節(jié)點唯一
zookeeper.connect：改成zookeeper節(jié)點

查看集群狀態(tài)：

bin/kafka-topics.sh --zookeeper <zookeeper_host>:<zookeeper_port> --describe

性能測試

sh bin/kafka-producer-perf-test.sh --help
sh bin/kafka-consumer-perf-test.sh --help

到了這里，關(guān)于中間件： Kafka安裝部署的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！

本文來自互聯(lián)網(wǎng)用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務(wù)，不擁有所有權(quán)，不承擔(dān)相關(guān)法律責(zé)任。如若轉(zhuǎn)載，請注明出處：如若內(nèi)容造成侵權(quán)/違法違規(guī)/事實不符，請點擊違法舉報進行投訴反饋，一經(jīng)查實，立即刪除！

分享到：

領(lǐng)支付寶紅包贊助服務(wù)器費用

【中間件】消息中間件之Kafka
一、概念介紹 Apache Kafka是一個分布式流處理平臺，用于構(gòu)建實時數(shù)據(jù)管道和流應(yīng)用。它可以處理網(wǎng)站、應(yīng)用或其他來源產(chǎn)生的大量數(shù)據(jù)流，并能實時地將這些數(shù)據(jù)流傳輸?shù)搅硪粋€系統(tǒng)或應(yīng)用中進行處理。核心概念： Topic（主題）：消息的分類，用于區(qū)分不同的業(yè)務(wù)消息。
2024年01月20日
瀏覽(42)
中間件 kafka
Kafka（Apache Kafka）是一個非常流行的開源分布式流數(shù)據(jù)平臺。它最初由LinkedIn開發(fā)，后來捐贈給了Apache基金會，并成為頂級項目。Kafka被設(shè)計用于處理實時數(shù)據(jù)流，具有高吞吐量、可擴展性和持久性。 Kafka 的主要特點和用途包括：發(fā)布-訂閱模型： Kafka 提供了一種發(fā)布-訂閱（
2024年02月13日
瀏覽(21)
Kafka消息中間件（Kafka與MQTT區(qū)別）
Kafka是一個分布式流處理平臺，它可以快速地處理大量的數(shù)據(jù)流。Kafka的核心原理是基于發(fā)布/訂閱模式的消息隊列。Kafka允許多個生產(chǎn)者將數(shù)據(jù)寫入主題（topic）中，同時也允許多個消費者從主題中讀取數(shù)據(jù)。 Kafka重要原理 Kafka的設(shè)計原則之一是高可用性和可擴展性，因此它
2024年02月03日
瀏覽(30)
消息中間件（二）——kafka
在大數(shù)據(jù)中，會使用到大量的數(shù)據(jù)。面對這些海量的數(shù)據(jù)，我們一是需要做到能夠收集這些數(shù)據(jù)，其次是要能夠分析和處理這些海量數(shù)據(jù)。在此過程中，需要一套消息系統(tǒng)。 Kafka專門為分布式高吞吐量系統(tǒng)設(shè)計。作為一個消息代理的替代品，Kafka往往做的比其他消息中間
2024年02月07日
瀏覽(29)
消息中間件 —— 初識Kafka
1.1.1、為什么要有消息隊列？ 1.1.2、消息隊列消息 Message 網(wǎng)絡(luò)中的兩臺計算機或者兩個通訊設(shè)備之間傳遞的數(shù)據(jù)。例如說：文本、音樂、視頻等內(nèi)容。隊列 Queue 一種特殊的線性表（數(shù)據(jù)元素首尾相接），特殊之處在于只允許在首部刪除元素和在尾部追加元素(FIFO)。入隊、出
2024年02月13日
瀏覽(24)
中間件（三）- Kafka（二）
6.1 Kafka的高效讀寫順序?qū)懘疟P Kafka的producer生產(chǎn)數(shù)據(jù)，需要寫入到log文件中，寫的過程是追加到文件末端，順序?qū)懙姆绞?，官網(wǎng)有數(shù)據(jù)表明，同樣的磁盤，順序?qū)懩軌虻?00M/s，而隨機寫只有200K/s，這與磁盤的機械結(jié)構(gòu)有關(guān)，順序?qū)懼钥?，是因為其省去了大量磁頭尋址的時
2024年02月07日
瀏覽(22)
大數(shù)據(jù)中間件——Kafka
Kafka安裝配置首先我們把kafka的安裝包上傳到虛擬機中：解壓到對應(yīng)的目錄并修改對應(yīng)的文件名：首先我們來到kafka的config目錄，我們第一個要修改的文件就是server.properties文件，修改內(nèi)容如下：主要修改三個部分，一個是唯一標(biāo)識id，kafka的文件存儲路徑，一個是zookeeper的節(jié)
2024年02月07日
瀏覽(23)
消息中間件之Kafka(一)
高性能的消息中間件，在大數(shù)據(jù)的業(yè)務(wù)場景下性能比較好，kafka本身不維護消息位點，而是交由Consumer來維護，消息可以重復(fù)消費，并且內(nèi)部使用了零拷貝技術(shù)，性能比較好 Broker持久化消息時采用了MMAP的技術(shù)，Consumer拉取消息時使用的sendfile技術(shù) Kafka是最初由Linkedin公司開發(fā)，
2024年01月20日
瀏覽(53)
消息中間件之Kafka(二)
1.1 為什么要對topic下數(shù)據(jù)進行分區(qū)存儲? 1.commit log文件會受到所在機器的文件系統(tǒng)大小的限制，分區(qū)之后可以將不同的分區(qū)放在不同的機器上，相當(dāng)于對數(shù)據(jù)做了分布式存儲，理論上一個topic可以處理任意數(shù)量的數(shù)據(jù) 2.提高并行度 1.2 如何在多個partition中保證順序消費? 方案一
2024年01月21日
瀏覽(29)
【Java面試丨消息中間件】Kafka
1. 介紹使用kafka在消息的收發(fā)過程都有可能會出現(xiàn)消息丟失（1）生產(chǎn)者發(fā)送消息到broker丟失（2）消息在broker中存儲丟失（3）消費者從broker接收消息丟失 2. 生產(chǎn)者發(fā)送消息到broker丟失設(shè)置異步發(fā)送：同步發(fā)送會發(fā)生阻塞，一般使用異步發(fā)送方式發(fā)送消息消息重試：由于網(wǎng)
2024年02月11日
瀏覽(30)