日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

kafka 集群_单机版kafka集群部署

發布時間:2024/9/30 编程问答 33 豆豆
生活随笔 收集整理的這篇文章主要介紹了 kafka 集群_单机版kafka集群部署 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

前言

分布式消息隊列是大型分布式系統不可缺少的中間件,主要解決應用耦合、異步消息、流量削鋒等問題。實現高性能、高可用、可伸縮和最終一致性架構。

今天跟大家講解下如何部署單機Kafka集群,希望大家喜歡。

Kafka是什么?

Kafka 是由 LinkedIn 開發的一個分布式的消息系統,使用 Scala 編寫,它以可水平擴展和高吞吐率而被廣泛使用。

它的特點:

它同時為發布和訂閱提供高吞吐量;它支持多訂閱者,當失敗時能自動平衡消費者;它將消息持久化到磁盤,因此可用于批量消費。

Kafka概念

說到Kafka,自然離不開三個專業術語:生產者(Producer)、消費者(Consumer)、主題(Topic)。

專業術語

我們再來看這個圖,大致會有一定的了解了。

了解了一些基本知識,下面開始講解下如何部署。

部署環境

本次是以CentOS6 環境為例子,介紹下如何快速搭建。

官網下載地址

https://archive.apache.org/dist/kafka/

這里我以2.1.0版本為例

https://archive.apache.org/dist/kafka/2.1.0/kafka_2.12-2.1.0.tgz

部署zookeeper

這里不展開描述,有興趣的可以參考我之前寫的文章:中間件-簡單部署zookeeper

部署kafka

  • 新建獨立目錄
$ pwd/opt/testerzhang/3rd/kafka2.1
  • 解壓包,并重命名文件夾名
$ tar zxf kafka_2.12-2.1.0.tgz$ mv kafka_2.12-2.1.0 kafka1
  • 每個節點配置文件配置節點1
$ vi kafka1/config/server.properties# 每個節點值不一樣broker.id=10# 端口地址port=9110#配置當前主機hostname,也可以IPhost.name=10.10.10.10#配置對應的zookeepr地址zookeeper.connect=10.10.10.10:15001,10.10.10.10:15002,10.10.10.10:15003#在配置集群的時候,必須設置listeners = PLAINTEXT://10.10.10.10:9110#存放log目錄log.dirs=/opt/testerzhang/3rd/kafka2.1/data/kafka1-log
  • 節點2
$ cp -rf kafka1 kafka2$ vi kafka2/config/server.properties# 每個節點值不一樣broker.id=11# 端口地址port=9111#配置當前主機hostname,也可以IPhost.name=10.10.10.10#配置對應的zookeepr地址zookeeper.connect=10.10.10.10:15001,10.10.10.10:15002,10.10.10.10:15003#在配置集群的時候,必須設置listeners = PLAINTEXT://10.10.10.10:9111#存放log目錄log.dirs=/opt/testerzhang/3rd/kafka2.1/data/kafka2-log
  • 節點3
$ cp -rf kafka1 kafka3$ vi kafka3/config/server.properties# 每個節點值不一樣broker.id=12# 端口地址port=9112#配置當前主機hostname,也可以IPhost.name=10.10.10.10#配置對應的zookeepr地址zookeeper.connect=10.10.10.10:15001,10.10.10.10:15002,10.10.10.10:15003#在配置集群的時候,必須設置listeners = PLAINTEXT://10.10.10.10:9112#存放log目錄log.dirs=/opt/testerzhang/3rd/kafka2.1/data/kafka3-log
  • 啟動方法
$ cd /opt/testerzhang/3rd/kafka2.1/kafka1/bin$ nohup sh ./kafka-server-start.sh ../config/server.properties &

這樣,單機版Kafka集群搭建完畢,開始玩起來吧。

下次跟大家分享下如何可視化操作Kafka,敬請期待。


我是testerzhang,喜歡本文的童鞋,可以關注我+收藏,不明白的地方也可以評論留言。

總結

以上是生活随笔為你收集整理的kafka 集群_单机版kafka集群部署的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。