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會自動創建