1. kafka官網提供測試指令碼
(1) 生產者測試指令碼kafka-producer-perf-test.sh
引數說明:
--topic topic名稱,
--num-records 總共需要傳送的訊息數,
--record-size 每個記錄的位元組數,
--throughput 每秒鐘傳送的記錄數,
--producer-props bootstrap.servers=localhost:9092 傳送端的配置資訊
(2)消費者測試指令碼kafka-consumer-perf-test.sh
引數說明:
--zookeeper 指定zookeeper的鏈結資訊,
--topic 指定topic的名稱,
--fetch-size 指定每次fetch的資料的大小,
--messages 總共要消費的訊息個數,
kafka效能測試
版本0.10.1.1 kafka broker的jvm預設是使用1g的記憶體 bin kafka producer perf test.sh topic test pati3 rep2 throughput 500000 num records 1500000 record size 1000 pr...
kafka效能測試
目前我測試過kafka的消費效能測試 一般kafka的消費大體有兩種,一種是定時消費,一種是實時消費 不論哪一種消費,我們都需要了解kafka的配置,配置檢視命令 grep e v kafka 2.11 1.1.1 config server.properties 備註 當kafka刪除資料後,偏移...
kafka效能測試1 0 0
kafka提供工具kafka producer perf test.sh用以壓測,引數說明 messages 生產者傳送總的訊息數量 message size 每條訊息大小 batch size 每次批量傳送訊息的數量 topics 生產者傳送的topic threads 生產者使用幾個執行緒同時傳...