Products
96SEO 2025-06-11 11:48 1
Kafka作为一款分布式流处理平台,其性能的优劣直接关系到到整个系统的稳稳当当性和效率。所以呢,对Kafka进行性能测试显得尤为关键。
先说说我们需要在Debian周围下搭建Kafka集群。
sudo apt update
sudo apt install openjdk-11-jdk -y
wget https://www.apache.org/dyn/closer.cgi?path=/kafka/3.6.1/kafka_2.13-3.6.1.tgz -xzf kafka_2.13-3.6.1.tgz /opt/kafka
部署Kafka集群基本上包括以下步骤:
vi /opt/kafka/config/server.properties
设置以下配置项:
listeners=PLAINTEXT://:9092
sudo /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
用Kafka自带的性能测试脚本对生产者和消费者进行测试。
/opt/kafka/bin/kafka-producer-perf-test.sh --topic perf-test --num-records 1000 --record-size 1024 --throughput 10000 --producer-props bootstrap.servers=localhost:9092,linger.ms=10
/opt/kafka/bin/kafka-consumer-perf-test.sh --bootstrap-server localhost:9092 --topic perf-test --messages 1000000 --threads 8 --reporting-interval 1000 --show-detailed
,并根据测试后来啊进一步调整Kafka的配置以优化性能。
Demand feedback