1. 程式人生 > >Spring Cloud (3) | spring cloud bus 訊息匯流排kafka應用

Spring Cloud (3) | spring cloud bus 訊息匯流排kafka應用

1. 下載kafka,地址:http://kafka.apache.org/downloads.html




從上面可以看出,分為原始碼包和二進位制包,我們下載二進位制包,這兩個選其中一個就可以,在這裡我們選擇下載:kafka_2.12-0.11.0.1.tgz

2. 解壓二進位制包

 tar xf kafka_2.12-0.11.0.1.tgz

  解壓之後出現的目錄結構如下:

kafka
  +-bin
    +-windows
  +-config
  +-libs
  +-logs
  +-site-docs

3. 配置檔案, 切換到kafka_2.12-0.11.0.1目錄中,執行以下命令:

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

  如果執行上面的命令,throws下面的error:


 錯誤: 找不到或無法載入主類 config.zookeeper.properties

 極有可能你下載的是source原始碼包,如果出現上面問題,建議重新下載二進位制包,請參照步驟1



相關推薦

Spring Cloud (3) | spring cloud bus 訊息匯流排kafka應用

1. 下載kafka,地址:http://kafka.apache.org/downloads.html 從上面可以看出,分為原始碼包和二進位制包,我們下載二進位制包,這兩個選其中一個就可以,在這裡我們選擇下載:kafka_2.12-0.11.0.1.tgz 2. 解

Spring Cloud 進階之路 -- 訊息匯流排 Spring Cloud Bus 配置手動重新整理和動態自動重新整理

Spring Cloud Bus 配置步驟: 1、Spring Cloud Config 專案引入依賴,新增配置,配置暴露 endpoints 2、啟動Config 專案,註冊到Eureka,自動新增RabbitMQ佇列 3、客戶端的order應用引入依賴及配置,啟動Con

Spring Cloud Bus(訊息匯流排)(1)

訊息代理 訊息代理是一種訊息驗證、傳輸、路由的架構模式。它在應用程式之間起到通訊排程並最小化應用之間的依賴作用,使得應用程式可以高效地解耦通訊過程。訊息代理是一箇中間件產品,它的核心是一個訊息的路由程式,用來實現接受和分發訊息,並根據設定好的訊息處理流來轉發給正確的應用。它包括獨立的通訊和訊

走進Spring Cloud之十一 SpringCloud bus 訊息匯流排重新整理配置(Greenwich版本)

走進Spring Cloud之十一 SpringCloud bus 訊息匯流排重新整理配置(Greenwich版本) SpringCloud Bus 改造config-client pom.xml bootstrap.yml

springcloud系列—Bus—第7章-1: Spring Cloud bus 訊息匯流排

參考:https://www.jianshu.com/p/730d86030a41 目錄 RabbitMQ實現訊息匯流排 spring boot 整合 RabbitMQ RabbitMQ實現訊息匯流排 原理分析 指定重新整理範圍 架構優化 kafka實現訊息匯流排

SpringCloud教程 | 第13篇:高可用的分散式配置中心 Spring Cloud Bus 訊息匯流排整合(RabbitMQ)

上一篇文章,留了一個懸念,Config Client 實現配置的實時更新,我們可以使用 /refresh 介面觸發,如果所有客戶端的配置的更改,都需要手動觸發客戶端 /refresh ,當服務越來越多的時候,那豈不是維護成本很高,顯然不太合適,而使用Spring Cloud

一起來學Spring Cloud | 第八章:訊息匯流排(Spring Cloud Bus)

上一章節,我們講解了分散式配置中心spring cloud config,我們把配置項存放在git或者本地,當我們修改配置時,需要重新啟動服務才能生效。但是在生產上,一個服務部署了多臺機器,重新啟動比較麻煩且會短暫影響使用者體驗。spring cloud生態在發展,肯定有對應的解決之法,接下來將要講解的Spr

跟我學SpringCloud | 第八篇:Spring Cloud Bus 訊息匯流排

SpringCloud系列教程 | 第八篇:Spring Cloud Bus 訊息匯流排 Springboot: 2.1.6.RELEASE SpringCloud: Greenwich.SR1 如無特殊說明,本系列教程全採用以上版本 前面兩篇文章我們聊了Spring Cloud Config配置

Spring Cloud第十二篇 | 訊息匯流排Bus

​ ​本文是Spring Cloud專欄的第十二篇文章,瞭解前十一篇文章內容有助於更好的理解本文: Spring Cloud第一篇 | Spring Cloud前言及其常用元件介紹概覽 Spring Cloud第二篇 | 使用並認識Eureka註冊中心 Spring Cloud第三篇 | 搭建高可

Spring Cloud 系列之 Bus 訊息匯流排

什麼是訊息匯流排 訊息代理中介軟體構建一個共用的訊息主題讓所有微服務例項訂閱,當該訊息主題產生訊息時會被所有微服務例項監聽和消費。 訊息代理又是什麼?訊息代理是一個訊息驗證、傳輸、路由的架構模式,主要用來實現接收和分發訊息,並根據設定好的訊息處理流來轉發給正確的應用。它在微服務之間起到通訊排程作用,減少了服

Spring Cloud:配置中心和訊息匯流排(終結版)(09)

我們在springcloud(七):配置中心svn示例和refresh中講到,如果需要客戶端獲取到最新的配置資訊需要執行refresh,我們可以利用webhook的機制每次提交程式碼傳送請求來重新整理客戶端,當客戶端越來越多的時候,需要每個客戶端都執行一遍,這種方案就不太適合了。使用Spring C

Spring Cloud重新整理配置中心配置——訊息匯流排RabbitMQ

在http://blog.csdn.net/a60782885/article/details/69415527的最後,我們提到了配置的重新整理,但是這顯然是麻煩的,如果多個服務使用了這個配置,當我們修改配置資訊的時候,如果我們希望服務的配置也跟著修改,我們就不得不一個一個

Spring Cloud構建微服務架構: 訊息匯流排

Spring Cloud Bus除了支援RabbitMQ的自動化配置之外,還支援現在被廣泛應用的Kafka。在本文中,我們將搭建一個Kafka的本地環境,並通過它來嘗試使用Spring Cloud Bus對Kafka的支援,實現訊息匯流排的功能。由於本文會以之前Rabbit的實現作為基礎來修改,所以先閱讀《S

Spring boot-(3) Spring Boot特性1

ole child exce des boolean one other ascii碼 jvm 本節將深入Spring Boot的細節,可以學到你想使用的或定制的Spring Boot的主要特性。 1. SpringApplication SpringApplication

Spring boot-(3) Spring Boot特性2

覆蓋 -s json tde div mva ann opened 運行時 1. 外部配置 Spring Boot支持外部配置,以便可以在不同的環境中使用相同的應用程序代碼。可以使用properties文件,YAML文件,環境變量或命令行參數進行外部配置。可以使用@Valu

spring 筆記3: Spring 多環境配置檔案切換

使用Spring進行開發時,需要面對不同的執行環境,比如開發環境、測試環境、生產環境等。大多時候不同的環境需要不同的配置檔案。網上很多資料都是使用Spring的Bean definition profiles 功能來實現(https://docs.spring.io/spring/docs/4.2.

springCloud(F版)(7)——config分散式配置中心及bus訊息匯流排

前面我們已經建立了一個系統結構,包括Eureka配置中心,slueth(zipkin)服務追蹤,ribbon及feign負載均衡,zuul路由閘道器,hystrix斷路器、dashboard監控、turbine聚合監控等。下面來學習瞭解一下config配置中心,如何將配置中心註冊到eureka進

SpringCloud系列——Bus 訊息匯流排 SpringCloud系列——Config 配置中心

  前言   SpringCloud Bus使用輕量級訊息代理將分散式系統的節點連線起來。然後可以使用此代理廣播狀態更改(例如配置更改)或其他管理指令。本文結合RabbitMQ+GitHub的Webhook實現上篇部落格Config配置中心(SpringCloud系列——Config 配置中心)的自動重新整

SpringCloud(十四)springCloud bus 訊息匯流排重新整理配置

前言:     在微服務中,我們將使用輕量級訊息代理,通過一個共用的訊息主題,讓系統中所有微服務都連上來,主題中的訊息會被所有監聽者消費,所以稱為訊息匯流排。spring cloud bus將分散式節點用輕量級訊息連線起來,他可以用於服務間通訊,例如:配置檔案的更改。可以用k

史上最簡單的SpringCloud教程 | 第八篇: 訊息匯流排(Spring Cloud Bus)

最新Finchley版本請訪問: https://www.fangzhipeng.com/springcloud/2018/08/30/sc-f8-bus/ 或者 http://blog.csdn.net/forezp/article/details/81041062