点击查看原文

Jmeter连接Kafka

在jmeter/lib/ext中导入一个kafka相关的jar包，如下图：
导入之后就可以打开JMeter进行操作了，首先在一个Thread group中添加一个Java request：
选择相应的Classname，配置相关参数
- 编辑brokers，topic，key和message即可
- broker地址：配置文件里的advertised.listener,也就是外网地址和访问端口,这个地址和端口能定位到唯一个broker，通过配置可以分发到多个broker上，地址用逗号隔开即可。
- 变量引用：${Name}（自定义变量方法见下文）

配置好后，点击运行，就能在消费者终端消费到消息了

参考：https://blog.csdn.net/jwcxs_m/article/details/103530869

自定义变量并查看

自定义变量的方法有很多种，可以直接在线程组配置中添加自定变量

这里通过JSON提取器将提取出的结果保存在新建变量中

新建变量

右键HTTP请求选择后置处理器添加JSON提取器

顾名思义是要对返回的JSON数据进行提取处理
配置相关信息——将提取出的JSON数据保存在自定义的变量

提取表达式：查看JSON Path使用文档

变量查看

添加调试取样器，即可在运行后通过查看结果树查看取样器的返回结果

右击线程组添加调试取样器（Debug Sample）

调试取样器的配置则规定在监听器中会显示哪些内容

将 Jmeter 变量设为 true 意为将在结果中显示 Jmeter变量
运行后，通过查看结果树查看取样结果

可以将这个变量通过${data}填入kafka配置的kafka_message中传入kafka

更多：https://www.cnblogs.com/jessicaxu/p/7512680.html

Linux运行Jmeter脚本

下载安装Jmeter

Jmeter的安装包本来就包括了Windows和Linux，所以只要在本地下载好jmeter，然后用secureCRT上传到服务器就可以了。

在服务器上解压zip文件：

unzip 文件名.zip

进行Jmeter测试

jmeter -n -X -t test.jmx -l result.jtl

常用命令：
-h 帮助：打印出有用的信息并退出
-n 非 GUI 模式：在非 GUI 模式下运行 JMeter
-t 测试文件：要运行的 JMeter 测试脚本文件
-l 日志文件：记录结果的文件
-r 远程执行：启动远程服务
-H 代理主机：设置 JMeter 使用的代理主机
-P 代理端口：设置 JMeter 使用的代理主机的端口号

通过jtl文件查看结果

导出生成的.jtl文件
xshell中导出文件命令
```
sz FileName
```
查看报告
启动jmeter，新建一个线程组，添加所需的监听器，导入脚本运行产生的.jtl文件，如下：

参考：https://blog.csdn.net/woshilishu/article/details/89641263
https://www.cnblogs.com/imyalost/p/9808079.html

Jmeter向kafka发送数据相关推荐

linux 中kafka发送数据,C++ 向kafka中发送数据
kafka是一个分布式流处理的平台,通过kafka我们可以发布和订阅流式记录.有关kafka的介绍可以参考官网或者这篇文章https://juejin.im/post/6844903495670169 ...
【kafka】kafka 发送数据发送失败回调函数怎么能记录异常的消息内容
本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 文章目录 1.概述 1.概述一个网友迷糊了,问题如下
Flume均匀发送数据到kafka的partition配置UUID Interceptor生成key的坑
一.需求 Flume向kafka发送数据时,同一个flume发送到kafka的数据总是固定在某一个partition中.而业务需求是发送的数据在所有的partition平均分布二.实现 Flume的 ...
JMeter发送数据到Kafka
最近为了简单做一下性能测试,开始使用JMeter了,因为要先往Kafka中灌入数据,毕竟没用过JMeter,就在网上各种搜,发现写的都不是自己所需要的那种,即使是有的博客看着好像是符合自己要求,但是还 ...
discard connection丢失数据_python kafka 生产者发送数据的三种方式
python kafka 生产者发送数据的三种方式发送方式同步发送发送数据耗时最长有发送数据的状态,不会丢失数据,数据可靠性高以同步的方式发送消息时,一条一条的发送,对每条消息返回的结果判断 ...
Kafka Sender线程如何发送数据
文章目录 1.内存缓冲中的Batch,如何被判定可发送出去 2.标识那些元数据未拉取成功的 3.检查筛选出来的Broker是否可以发送数据 3.1 元数据是否已经就位 3.2 是否可以发送请求 3.3 ...
kafka异步发送数据_在Kafka上异步发送数据
kafka异步发送数据对于一个项目,我试图记录用户的基本交易,例如添加和删除一个项目以及多种类型的项目,并为每笔交易向kafka发送一条消息. 日志机制的准确性不是至关重要的,在kafka服务器停机 ...
在Kafka上异步发送数据
对于一个项目,我试图记录用户的基本交易,例如添加和删除一个项目以及多种类型的项目,并为每笔交易向kafka发送一条消息. 日志机制的准确性不是至关重要的,在kafka服务器停机的情况下,我不希望它阻止 ...
java调用kafka接口发送数据_Java调用Kafka生产者，消费者Api及相关配置说明
本次的记录内容包括: 1.Java调用生产者APi流程 2.Kafka生产者Api的使用及说明 3.Kafka消费者Api的使用及说明 4.Kafka消费者自动提交Offset和手动提交Offset ...

Jmeter向kafka发送数据