目录

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

二.测试kafka的案例

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

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

 

二.测试kafka的案例

install -d /tmp/kafka-test/
cat > oldboyedu-kafka-test.sh <<'EOF'
kafka-topics.sh --bootstrap-server 10.0.0.111:9092,10.0.0.112:9092,10.0.0.113:9092 --topic oldboyedu-kafka-2021-001 --replication-factor 1 --partitions 10 --create
nohup kafka-consumer-perf-test.sh --broker-list 10.0.0.111:9092,10.0.0.112:9092,10.0.0.113:9092 --topic oldboyedu-kafka-2021-001 --messages 100000000 &>/tmp/kafka-test/oldboyedu-kafka-consumer.log &
nohup kafka-producer-perf-test.sh --num-records 100000000 --record-size 1000 --topic oldboyedu-kafka-2021-001 --throughput 1000000 --producer-props bootstrap.servers=10.0.0.111:9092,10.0.0.112:9092,10.0.0.113:9092 &> /tmp/kafka-test/oldboyedu-kafka-producer.log &
EOF
温馨提示:
参考链接: https://www.cnblogs.com/yinzhengjie/p/9953212.html