kafka的部署和jmeter连接kafka
zookeeper的安装
kafka依赖Zookeeper所以要先安装Zookeeper
kafka的安装文章引用来源:Kafka下载和使用（linux版）-CSDN博客
通过wget命令安装
# 安装wget https://downloads.apache.org/zookeeper/stable/apache-zookeeper-3.7.1-bin.tar.gz# 解压tar -xvzf apache-zookeeper-3.7.1-bin.tar.gz进入Zookeeper的bin目录，创建Zookeeper的配置文件 zoo.cfg：
cp conf/zoo_sample.cfg conf/zoo.cfgzoo.cfg修改以下内容
dataDir=/tmp/zookeeper
clientPort=2181
启动Zookeeper和验证Zookeeper
bin/zkServer.sh
bin/zkServer.sh status
下载安装kafka
下载kafka
https://kafka.apache.org/downloads
解压kafka
tar -xvzf kafka_2.13-3.8.1.tgzkafka配置
broker.id=0
#listeners=PLAINTEXT://localhost:9092
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://8.133.253.43:9092
zookeeper.connect=8.133.253.43:2181
log.dirs=/tmp/kafka-logs启动kafka
bin/kafka-server-start.sh config/server.properties
验证kafka
ps aux | grep kafka
创建kafka主题
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1查看kafka主题
bin/kafka-topics.sh --list --bootstrap-server localhost:9092向Kafka主题发送消息
echo "Hello, Kafka" | bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092消费Kafka主题的消息
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092关闭Kafka和Zookeeper
停止Kafka
bin/kafka-server-stop.sh停止Zookeeper
bin/zkServer.sh stop
jmeter连接kafka向kafka发送消息
下载链接kafka的jar包
下载jmeter连接kafka的地址
GitCode - 全球开发者的开源社区,开源代码托管平台
将jar包拷入\lib\ext的目录下
E:\apache-jmeter-5.6.3\apache-jmeter-5.6.3\lib\ext
jmeter配置kafka消息
配置元件--Kafka Producer Config
配置连接kafka的地址和端口号
添加配置kafka的请求
添加---取样器---Kafka Producer Sampler
不存在的topic时在jmeter连接的过程中kafka会自动创建
