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.cfg

zoo.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.tgz

kafka配置

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会自动创建