kafka集群的压力测试

一.为什么要对kafka集群进行压测

    (1)了解当前集群的处理能力的上限;
    (2)当修改集群的配置参数后，协助运维人员参考调优的结果;
    (3)以后参考压测的结果对集群进行扩容，留下有效的证据;

二.测试kafka的案例

install -d /tmp/kafka-test/

vi oldboyedu-kafka-test.sh 
inohup kafka-consumer-perf-test.sh --broker-list 10.0.0.106:9092,10.0.0.107:9092,10.0.0.108:9092 --topic oldboyedu-kafka-2021 --messages 100000000 --fetch-size 1048576 --threads 10  &> /tmp/kafka-test/oldboyedu-kafka-consumer.log &

nohup kafka-producer-perf-test.sh --num-records 100000000 --record-size 1000 --topic oldboyedu-kafka-2021 --throughput 1000000 --producer-props bootstrap.servers=10.0.0.106:9092,10.0.0.107:9092,10.0.0.108:9092 &> /tmp/kafka-test/oldboyedu-kafka-producer.log &

温馨提示:
    参考链接: https://www.cnblogs.com/yinzhengjie/p/9953212.html