Skip to content

Instantly share code, notes, and snippets.

View ranjitreddy2013's full-sized avatar

Ranjit Lingaiah ranjitreddy2013

View GitHub Profile
# init csv file
echo "numPartitions, sizeMsg, topicCount, numMessages, Average nMsgs/sec, Average nKBs/sec, Average latency (ms), eth0 TX kB/s, eth0 RX kB/s" >> partitions-kafka.csv
for NUMPARTITIONS in 1 2 3 4 5 6 7 8 9 10 15 20 25 30 35 40 45 50 60 70 80 90 100 150 200 250 300 350 400; do
~/cleanup.sh >& /dev/null
sleep 5
TOPIC='iantest-'$NUMPARTITIONS
MESSAGES=1000000