Kafka性能測試分析

首先要特別感謝趙崇賀同學(xué)利用業(yè)余時間進(jìn)行的壓測,才能為本文提供專業(yè)的測試數(shù)據(jù)

一临梗、測試環(huán)境準(zhǔn)備

?Cpu ?內(nèi)存 硬盤
Intel(R) Xeon(R) CPU E5520 @ 2.27GHz 32G 6T

Kafka集群,服務(wù)器個數(shù):3臺
采用CMS垃圾回收

JVM運行參數(shù)

-Xmx1G -Xms1G -server -XX:+UseParNewGC -XX:+UseConcMarkSweepGC 
-XX:+CMSClassUnloadingEnabled -XX:+CMSScavengeBeforeRemark -XX:+DisableExplicitGC -Djava.awt.headless=true 
-Xloggc:/usr/local/kafka_2.10-0.8.2.2/bin/../logs/kafkaServer-gc.log -verbose:gc 
-XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCTimeStamps 
-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false 
-Dcom.sun.management.jmxremote.ssl=false
-Dkafka.logs.dir=/usr/local/kafka_2.10-0.8.2.2/bin/../logs
-Dlog4j.configuration=file:/usr/local/kafka_2.10-0.8.2.2/bin/../config/log4j.properties

Kafka server端配置

broker.id=165
port=9092
host.name=hadoop165.kuaiyong.in
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400


socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
log.dirs=/download/kafka-logs
num.partitions=1
num.recovery.threads.per.data.dir=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
log.cleaner.enable=false

zookeeper.connect=hadoop165.xxx.in:2181,hadoop166.xxx.in:2181,hadoop167.xxx.in:2181

zookeeper.connection.timeout.ms=6000

測試命令行如下

生產(chǎn)者:

bin/kafka-producer-perf-test.sh --broker-list=hadoop02:9092 
--messages 100000 --topic s1 --threads 10 --message-size 1000 
--batch-size 200 --compression-codec 1

消費者

bin/kafka-consumer-perf-test.sh --zookeeper hadoop03:2181 
--messages 500000 --topic s1 --threads 1

二、正常請求測試

1、Producer:

數(shù)據(jù)量:230萬條記錄
每次打包發(fā)送1000條數(shù)據(jù)
數(shù)據(jù)格式:采用壓縮格式

測試結(jié)果
最大處理量:39.2501MB/S
TPS:41156.6817條

2虏束、Consumer

耗時:18秒
總體文件大小:2193.45MB
最大處理量:163.6659MB/S
TPS:171616.1767條

三厦章、壓力請求測試

1镇匀、Producer

數(shù)據(jù)量:1000萬條數(shù)據(jù)
每次打包發(fā)送1000條數(shù)據(jù)
數(shù)據(jù)格式:采用壓縮格式

測試結(jié)果
耗時:242秒
總體文件大小:9536.74MB
最大處理量:39.2531MB/S
TPS:41159.8856條

2袜啃、Consumer

耗時:70秒
總體文件大锌勇伞:9536.74MB
最大處理量:145.4193MB/S
TPS:152483.1887條

結(jié)論:1000萬條下的壓力測試,性能有所降低囊骤,估計瓶頸期在500萬條左右

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市冀值,隨后出現(xiàn)的幾起案子也物,更是在濱河造成了極大的恐慌,老刑警劉巖列疗,帶你破解...
    沈念sama閱讀 222,807評論 6 518
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件滑蚯,死亡現(xiàn)場離奇詭異,居然都是意外死亡抵栈,警方通過查閱死者的電腦和手機(jī)告材,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,284評論 3 399
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來古劲,“玉大人斥赋,你說我怎么就攤上這事〔” “怎么了疤剑?”我有些...
    開封第一講書人閱讀 169,589評論 0 363
  • 文/不壞的土叔 我叫張陵滑绒,是天一觀的道長。 經(jīng)常有香客問我隘膘,道長疑故,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 60,188評論 1 300
  • 正文 為了忘掉前任弯菊,我火速辦了婚禮纵势,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘管钳。我一直安慰自己钦铁,他們只是感情好,可當(dāng)我...
    茶點故事閱讀 69,185評論 6 398
  • 文/花漫 我一把揭開白布蹋嵌。 她就那樣靜靜地躺著育瓜,像睡著了一般。 火紅的嫁衣襯著肌膚如雪栽烂。 梳的紋絲不亂的頭發(fā)上躏仇,一...
    開封第一講書人閱讀 52,785評論 1 314
  • 那天,我揣著相機(jī)與錄音腺办,去河邊找鬼焰手。 笑死,一個胖子當(dāng)著我的面吹牛怀喉,可吹牛的內(nèi)容都是我干的书妻。 我是一名探鬼主播,決...
    沈念sama閱讀 41,220評論 3 423
  • 文/蒼蘭香墨 我猛地睜開眼躬拢,長吁一口氣:“原來是場噩夢啊……” “哼躲履!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起聊闯,我...
    開封第一講書人閱讀 40,167評論 0 277
  • 序言:老撾萬榮一對情侶失蹤工猜,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后菱蔬,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體篷帅,經(jīng)...
    沈念sama閱讀 46,698評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,767評論 3 343
  • 正文 我和宋清朗相戀三年拴泌,在試婚紗的時候發(fā)現(xiàn)自己被綠了魏身。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 40,912評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡蚪腐,死狀恐怖箭昵,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情回季,我是刑警寧澤宙枷,帶...
    沈念sama閱讀 36,572評論 5 351
  • 正文 年R本政府宣布掉房,位于F島的核電站,受9級特大地震影響慰丛,放射性物質(zhì)發(fā)生泄漏卓囚。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 42,254評論 3 336
  • 文/蒙蒙 一诅病、第九天 我趴在偏房一處隱蔽的房頂上張望哪亿。 院中可真熱鬧,春花似錦贤笆、人聲如沸蝇棉。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,746評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽篡殷。三九已至,卻和暖如春埋涧,著一層夾襖步出監(jiān)牢的瞬間板辽,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,859評論 1 274
  • 我被黑心中介騙來泰國打工棘催, 沒想到剛下飛機(jī)就差點兒被人妖公主榨干…… 1. 我叫王不留劲弦,地道東北人。 一個月前我還...
    沈念sama閱讀 49,359評論 3 379
  • 正文 我出身青樓醇坝,卻偏偏與公主長得像邑跪,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子呼猪,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 45,922評論 2 361

推薦閱讀更多精彩內(nèi)容

  • 本文轉(zhuǎn)載自http://dataunion.org/?p=9307 背景介紹Kafka簡介Kafka是一種分布式的...
    Bottle丶Fish閱讀 5,475評論 0 34
  • 背景介紹 Kafka簡介 Kafka是一種分布式的画畅,基于發(fā)布/訂閱的消息系統(tǒng)。主要設(shè)計目標(biāo)如下: 以時間復(fù)雜度為O...
    高廣超閱讀 12,843評論 8 167
  • Kafka入門經(jīng)典教程-Kafka-about云開發(fā) http://www.aboutyun.com/threa...
    葡萄喃喃囈語閱讀 10,842評論 4 54
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理宋距,服務(wù)發(fā)現(xiàn)轴踱,斷路器,智...
    卡卡羅2017閱讀 134,716評論 18 139
  • Kafka系列一- Kafka背景及架構(gòu)介紹 Kafka簡介 Kafka是一種分布式的乡革,基于發(fā)布/訂閱的消息系統(tǒng)。...
    raincoffee閱讀 2,211評論 0 22