kafka-producer-perf-test.sh: Teste de Sarcină și Benchmarking în Apache Kafka

Utilitar integrat de testare a performanței și debitului maxim de scriere pe un cluster Kafka.

Sintaxă
kafka-producer-perf-test.sh --topic <nume> --num-records <nr> --record-size <bytes> --throughput <nr> --producer-props <proprietati>

Ce face kafka-producer-perf-test.sh

Este utilitarul standard inclus în distribuția Kafka pentru a valida capacitatea hardware a clusterului înainte de trecerea în producție. Poate injecta milioane de mesaje sintetice la debite controlate sau nelimitate, calculând automat procentilele de latență (50th, 95th, 99th, 99.9th) și lățimea de bandă (MB/sec).

Exemplu Concret: Generarea a 1.000.000 de mesaje de 1KB la debit maxim
kafka-producer-perf-test.sh \
  --topic benchmark-test \
  --num-records 1000000 \
  --record-size 1024 \
  --throughput -1 \
  --producer-props \
    bootstrap.servers=localhost:9092 \
    acks=1 \
    batch.size=65536 \
    linger.ms=10

# Rezultate afișate la final:
# 1000000 records sent, 185253.7 records/sec (180.91 MB/sec), 5.4 ms avg latency, 24.0 ms max latency.
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: kafka-producer-perf-test.sh: Teste de Sarcină și Benchmarking

Ai o nelămurire despre utilizarea comenzii kafka-producer-perf-test.sh: Teste de Sarcină și Benchmarking sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.