閱讀446 返回首頁    go 阿裏雲 go 技術社區[雲棲]


kafka

introduction
對於流平台 有三個關鍵的作用
1.它允許發布和記錄流 這方麵有點像消息隊列或者是信息係統
2.它運行以容錯的機製存儲流
3.允許處理流記錄

好處
1.建立實時流數據管道在係統和引用之間
2.建立實時流應用用於轉換或者響應數據

概念
kafka運行在集群上一個或者多個服務
kafka集群儲存流記錄在分類中這個分類被叫做topics
每條記錄由key value 和shij時間戳組成

kafka有四個核心API

生產者 Producer API :允許發布流記錄到topics上

消費者consummer API:允許一個應用讚成一個或者多個topics和流進程記錄生產他們

流 Streams API 允許應用以處理器 消費輸入流通過一個或者多個topics生產一個或者多個輸出topic 可以有效地將輸入流轉換為輸出流

連接 Connector API

kafka 的topic中存在的應用或者數據係統允許建立或者運行生產者或消費者 例如 age連接到關係型數據庫興許可以鋪貨所有改變的了的表.

在kafka中的客戶端和服務器之間的信息交流通過一個簡單 高效 與語煙無關的TCP 協議完成

核心抽象流記錄到topic中

topic是一個分區或者命名為可以記錄發布的分區

最後更新:2017-11-09 20:33:40

  上一篇:go  Android 經典筆記之八:網絡請求數據基礎介紹
  下一篇:go  曾經踩坑黨,如今護航忙 | 袋鼠雲的雙11故事之一