Kafka架構設計:分布式發布訂閱消息系統

【http://www.oschina.net/translate/kafka-design】(較長:很詳細的講解)

【我們為什么要搭建該系統】
用作LinkedIn的活動流(activity stream)和運營數據處理管道(pipeline)的基礎。
作為多種類型的數據管道(data pipeline)和消息系統使用。

活動流數據是所有站點在對其網站使用情況做報表時要用到的數據中最常規的部分。活動數據包括頁面訪問量(page view)、被查看內容方面的信息以及搜索情況等內容。這種數據通常的處理方式是先把各種活動以日志的形式寫入某種文件,然后周期性地對這些文件進行統計分析。

運營數據指的是服務器的性能數據(CPU、IO使用率、請求時間、服務日志等等數據)。運營數據的統計方法種類繁多。


【活動流數據的特點】
這種由不可變(immutable)的活動數據組成的高吞吐量數據流代表了對計算能力的一種真正的挑戰,因其數據量很容易就可能會比網站中位于第二位的數據源的數據量大10到100倍。
傳統的日志文件統計分析對報表和批處理這種離線處理的情況來說,是一種很不錯且很有伸縮性的方法;但是這種方法對于實時處理來說其時延太大,而且還具有較高的運營復雜度。另一方面,現有的消息隊列系統(messaging and queuing system)卻很適合于在實時或近實時(near-real-time)的情況下使用,但它們對很長的未被處理的消息隊列的處理很不給力,往往并不將數據持久化作為首要的事情考慮。這樣就會造成一種情況,就是當把大量數據傳送給Hadoop這樣的離線系統后, 這些離線系統每個小時或每天僅能處理掉部分源數據。Kafka的目的就是要成為一個隊列平臺,僅僅使用它就能夠既支持離線又支持在線使用這兩種情況。
Kafka支持非常通用的消息語義(messaging semantics)。盡管我們這篇文章主要是想把它用于活動處理,但并沒有任何限制性條件使得它僅僅適用于此目的。

?

更多內容,未完待續...

轉載于:https://www.cnblogs.com/lsx1993/p/4627400.html

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/273139.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/273139.shtml
英文地址,請注明出處:http://en.pswp.cn/news/273139.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

拼團php開發邏輯思維羅振宇_2019羅胖羅振宇跨年演講手動整理稿,看了兩遍

2019羅胖羅振宇跨年演講看了兩遍,手動整理文檔1.歲月不饒人,我們也沒饒了歲月2.你有你的計劃,原來這個世界另有計劃,既然這個世界另有計劃,我們就得重做計劃3.做事的人和不做事的人4.宏觀是我們必須忍受的,…

URLConnection

轉載(http://www.cnblogs.com/shyang--TechBlogs/archive/2011/03/21/1990525.html) 關于URLConnection,網上很多回答都是對API的翻譯,很崩潰,我是看了很多之后,然后看API才發現的。此后我會吸取教訓&#…

java文件拷貝_Java實現文件拷貝的4種方法

第一種方法:古老的方式public static long forJava(File f1,File f2) throws Exception{long timenew Date().getTime();int length2097152;FileInputStream innew FileInputStream(f1);FileOutputStream outnew FileOutputStream(f2);byte[] buffernew byte[length];while(tru…

今夜的硬件之旅

6腳繼電器: 匯科繼電器HK4100F-DC6V-SHG ①3A觸點切換能力 ②具有一組常開,一組轉換觸點形式 ③超小型,標準印刷制版引出腳 ④有塑封型 Outline(L*W*H)外形尺寸:15.510.511.8 Contact Date觸電形式&#…

mp3 pcm java_Java mp3文件轉pcm文件

Java mp3文件轉pcm文件package cn.zpy.util;import java.io.File;import java.io.IOException;import javax.sound.sampled.AudioFileFormat;import javax.sound.sampled.AudioFormat;import javax.sound.sampled.AudioInputStream;import javax.sound.sampled.AudioSystem;imp…

有1~5000一組亂序數列,請使用偽代碼對該數進行排列

先把1-5000組成一個數組 冒泡排序法 $arrarray(1,2,3,4,5,6,7,8,9.....5000); $totalcount($arr); For($i0;$i<$total;$i){ For($j0;$j<$total-1;$j){ If($arr[$j]>$arr[$j1]){ $tmp$arr[$i]; $arr[$j]$arr[$j1]; $arr[$j1]$tmp; } } } 快速排序法 $arrarray(1,2,3,4,…

java 類型轉換方法_java數據類型轉換的常見方法

public class Testfun {public static void main(String[] args) {// (一)跨Number父類的類型轉換// 1、str轉int > Integer.parseInt(s1)String s1 "19";int i2 Integer.parseInt(s1);// 數字str轉化為對標的intSystem.out.println("i2" (i2));// 2…

json to java 在線_Json轉Java對象 (全網最簡版)

Json2Java(全網最簡版)json字符串轉Java對象,生成對應文件描述&特點簡易的Json轉Java工具,滿足基本日常使用(特殊需求可自行增添,代碼就一頁)在網上找了好些個這類工具,不是只暴露iead插件就是復雜&沒文檔,于是自己寫了個全網最簡版Json2Javaonly one file用法public c…

Material design 色彩

八月已過去&#xff0c;九月剛來到~暑假已過去~九月上學季~~又迎來了一個桂花飄香的季節&#xff0c;你是否有了新的目標和計劃~~所以在九月初始給大家帶來一個全新的東西&#xff08;ps&#xff1a;對于我來說是全新的東西&#xff09;——Material Design~~九月讓我們一起好好…

java logging api_Java Logging API - Tutorial

1.2. 創建一個logger包 java.util.logging提供了日志的功能&#xff0c;可以使用類似于下面的代碼來創建一個logger&#xff1a;import java.util.logging.Logger;private final static Logger LOGGER Logger.getLogger(MyClass.class .getName());1.3. LevelLog的等級反映了問…

內存查看工具RAMMAP說明

參考 Technet Process Private: 分配給單一Process專用的內存 Mapped File: 用來儲放檔案內容快取(Cache)的內存空間 Shared Memory: 標注給多個Process共用的內存分頁(Page&#xff0c;內存管理單位) Page Table: 用來描述虛擬內存位址的分頁表(裡面是一筆一筆的PTE&…

php接口和java接口_java和php接口的區別是什么

java和php接口的區別是&#xff1a;1、php接口中的抽象方法只能是public的&#xff0c;默認也是public權限&#xff1b;2、java中私有方法使用private修飾&#xff0c;供接口中的默認方法或者靜態方法調用。【相關學習推薦&#xff1a;php編程(視頻)】php:規范&#xff1a;接口…

成都優步uber司機第四組獎勵政策

萬能的優步成都團隊放出了優步司機第四組&#xff0c;一二三組獎勵已經驟降&#xff0c;在月末放出第四組車主檔&#xff0c;這是要讓一切歸于平靜的節奏么&#xff01;&#xff01;&#xff01; 滴滴快車單單2.5倍&#xff0c;注冊地址&#xff1a;http://www.udache.com/如何…

java hql多條件查詢_使用hql語句怎樣實現多條件查詢

展開全部這里只寫了DAO和業務62616964757a686964616fe59b9ee7ad9431333264623331邏輯組件、ACTION的具體實現類&#xff0c;PO和和接口自己應該會寫吧&#xff0c;HQL采用的是結合SQL的那種寫法&#xff0c;增刪改查全在里面了&#xff0c;修改下馬上就能跑了&#xff0c;不清楚…

BZOJ 1008 [HNOI2008]越獄

1008: [HNOI2008]越獄 Time Limit: 1 Sec Memory Limit: 162 MBSubmit: 5166 Solved: 2242[Submit][Status][Discuss]Description 監獄有連續編號為1...N的N個房間&#xff0c;每個房間關押一個犯人&#xff0c;有M種宗教&#xff0c;每個犯人可能信仰其中一種。如果相鄰房間…

android mysql開發工具_Android開發工具--adb的使用

adb(Android Debug Bridge)是Android提供的一個通用的調試工具&#xff0c;借助這個工具&#xff0c;我們可以管理設備或手機模擬器的狀態。還可以進行以下的操作&#xff1a;1、快速更新設備或手機模擬器中的代碼&#xff0c;如應用或Android系統升級&#xff1b;2、在設備上運…

java headless_使用Chrome Headless 快速實現java版數據的抓取

Java: cdp4j - Java library for CDP,使用這個類庫實現。maven引入&#xff1a;io.webfoldercdp4j1.1.0官方例子&#xff1a;import io.webfolder.cdp.Launcher;import io.webfolder.cdp.session.Session;import io.webfolder.cdp.session.SessionFactory;public class HelloWo…

閃回數據庫

Flashbacking a database means going back to a previous database state.閃回數據庫到之前數據庫的狀態The Flashback Database feature provides a way to quickly revert entire Oracle database to the state it was in at a past point in time. 閃回數據庫特性提供了一種…

Ruby on Rails Tutorial 第六章 用戶模型

1、用戶模型&#xff08;1&#xff09;數據庫遷移Rails默認使用關系數據庫存儲數據&#xff0c;數據庫中的表有數據行組成&#xff0c;每一行都有相應的列&#xff0c;對應數據屬性。把列名命名為相應的名字后&#xff0c;ActiveRecord會自動把他們識別為用戶對象的屬性。 $ ra…

java dcl 失效解決_DCL失效原因和解決方案

Java內存模型 在了解Java的同步秘密之前&#xff0c;先來看看JMM(Java Memory Model)。Java被設計為跨平臺的語言&#xff0c;在內存管理上&#xff0c;顯然也要有一個統一的模型。而且Java語言最大的特點就是廢除了指針&#xff0c;把程序員從痛苦中解脫出來&#xff0c;不…