Você precisa testar a performance de escrita do seu cluster #kafka?
Faça isto de uma manira simples e assertiva com este comando utilitário que vem na instalação padrão:
1
2
3
4
5
6
7
8
9
10
11
12
13
# Medir desempenho na produção de eventos:
# - registros com 51200 bytes (50KB)
# - lotes de 400KB cada
kafka-producer-perf-test.sh \
--topic 'meu_topico' \
--num-records 1000000 \
--record-size 51200 \
--throughput -1 \
--print-metrics \
--producer-props \
'acks=1' \
'bootstrap.servers=127.0.0.1:9092' \
'batch.size=409600'