当前位置: 首页 > news >正文

jmeter集成kafka测试

Kafka的使用

查看kafka的topic

./kafka-topics --bootstrap-server 10.1.9.84:9092 --list

查看topic信息

./kafka-topics --bootstrap-server 10.1.9.84:9092 --describe --topic topic_example_1

创建topic 创建topic名为test,分区数为8,副本数为1

./kafka-topics.sh --create --zookeeper 10.128.106.52:2181 --topic test --partitions 8 --replication-factor 1

修改topic

./kafka-topics.sh --zookeeper 10.128.106.52:2181 -alter --partitions 12 --topic test

删除topic

./kafka-topics.sh --zookeeper 10.128.106.52:2181 --delete --topic test

消费者

kafka-console-consumer.sh --bootstrap-server  10.1.9.84:9092 --topic topic_example_1

消费者-group

./kafka-consumer-groups.sh --bootstrap-server 10.1.9.84:9092 --list

消费者-指定group

./kafka-consumer-groups.sh --bootstrap-server 10.1.9.84:9092 --group ai-trace --describe

生产者

kafka-console-producer.sh --broker-list  10.1.9.84:9092 --topic topic_example_1

查看消费者性能

./kafka-consumer-perf-test.sh --broker-list 10.1.9.84:9092  --messages 500000

--topic test-topic

查看生产者性能

./kafka-producer-perf-test.sh --topic test-topic --num-records 500000

--record-size 200 --throughput -1 --producer-props bootstrap.servers=10.1.9.84:9092 acks=-1

验证方案

使用本地自带的验证方案

生产者

kafka-console-producer.sh --broker-list  10.1.9.84:9092 --topic topic_example_1

消费者

kafka-console-consumer.sh --bootstrap-server  10.1.9.84:9092 --topic topic_example_1

使用工具验证方案

生产者

通过jmeter集成kafka配置好对应的

  1. kafka_brokers
  2. Kafka_topic
  3. Kafka_meassage

以上三个属性对于kafka来讲都很重要

消费者

kafka-console-consumer.sh --bootstrap-server  10.1.9.84:9092 --topic topic_example_1

插件

kafkameter-0.2.2 放到jmeter安装路径下的lib/ext中

https://github.com/rahulsinghai/jmeter-backend-listener-kafka/releases/tag/jmeter-backend-listener-kafka-1.0.1

相关文章:

jmeter集成kafka测试

Kafka的使用 查看kafka的topic ./kafka-topics --bootstrap-server 10.1.9.84:9092 --list 查看topic信息 ./kafka-topics --bootstrap-server 10.1.9.84:9092 --describe --topic topic_example_1 创建topic 创建topic名为test,分区数为8,副本数为…...

Java面试题-UDP\TCP\HTTP

UDP UDP特性 (1)UDP是无连接的:发送数据之前不需要像TCP一样建立连接,也不需要释放连接,所以减少了发送和接收数据的开销 (2)UDP 使用尽最大努力交付:即不保证可靠交付 &#xff0…...

使用WPF模仿Windows记事本界面

本次仅模仿Windows记事本的模样&#xff0c;并未实现其功能。 所有代码如下&#xff1a; <Window x:Class"控件的基础使用.MainWindow"xmlns"http://schemas.microsoft.com/winfx/2006/xaml/presentation"xmlns:x"http://schemas.microsoft.com/…...

【目标检测】Co-DETR:ATSS+Faster RCNN+DETR协作的先进检测器(ICCV 2023)

论文&#xff1a;DETRs with Collaborative Hybrid Assignments Training 代码**&#xff1a;https://github.com/Sense-X/Co-DETR 文章目录 摘要一、简介二、本文方法2.1.概述2.2.协同混合分配训练2.3. 定制的正 Query 生成2.4. Co-DETR为何有效1、丰富编码器的监督2、通过减少…...

iOS QQ登录SDK升级后报错Duplicate interface definition for class ‘TencentOAuth‘修复

起因 最近发现QQ登录SDK sdk-Lite3.3.8 TencentOpenAPI 在部分手机上会崩溃到初始化位置_tencentOAuth [[TencentOAuth alloc] initWithAppId:appid andDelegate:self];&#xff0c; 比如&#xff1a;iPhone6p 版本12.5.4&#xff0c;iPhone8p 版本14.1&#xff0c;iPad版本1…...

laravel中锁以及事务的简单使用

一、首先来说一下什么是共享锁&#xff1f;什么是排他锁&#xff1f; 共享&#xff1a;我可以读 写 加锁 , 别人可以 读 加锁。 排他&#xff1a;只有我 才 可以 读 写 加锁 , 也就是说&#xff0c;必须要等我提交事务&#xff0c;其他的才可以操作。 二、简单例子实现加锁 锁…...

Vue+openlayers+projs4实现坐标转换

一、背景 有一堆点数据&#xff0c;需要在地图上标记&#xff0c;只知参考北京54坐标系或西安80坐标系&#xff0c;但具体是哪种不清楚&#xff0c;这时候就需要坐标转换。ps&#xff1a;EPSG&#xff1a;3857&#xff08;openlayers参照的坐标系&#xff09; 二、思路 1、研…...

09 创建型模式-建造者模式

1.建造者模式介绍&#xff1a; 建造者模式 (builder pattern), 也被称为生成器模式 , 是一种创建型设计模式 定义: 将一个复杂对象的构建与表示分离&#xff0c;使得同样的构建过程可以创建不 同的表示。 2.建造者模式要解决的问题 建造者模式可以将部件和其组装过程分开&am…...

4.9 多协议标记交换MPLS

思维导图&#xff1a; 前言&#xff1a; **4.9 多协议标记交换MPLS笔记** 1. **定义与背景**&#xff1a; - MPLS (多协议标记交换) 是一种由 IETF 开发的新协议。 - “多协议”意味着 MPLS 的上层可以使用多种协议。 - 该协议综合了多家公司的技术&#xff0c;如 C…...

【经历】在职8个月->丰富且珍贵

在职8个月->丰富且珍贵 2021-3~2021-11&#xff1a;面试进入一家做400电话的公司&#xff0c;我进入公司时&#xff0c;加上我只有四个人(老板、人事、业务)&#xff0c;开发只有我&#xff0c;所以&#xff1a;产品~设计~前端~后端~测试~上线~维护~培训&#xff0c;只有我自…...

使用GH(命令行)在本地提出Github上的issue、PR,合并PR

使用GH&#xff08;命令行&#xff09;在本地提出Github上的issue、PR&#xff0c;合并PR 前言 Github上的一些操作使用Git命令是无法完成的&#xff0c;因此正常流程就是在网页端进行。等一下&#xff0c;你让程序员用网页进行&#xff1f;果然&#xff0c;有命令行工具可以…...

@Scheduled定时器

Scheduled定时器 一、基本使用二、参数说明fixedDelayfixedRateinitialDelaycron 三、cron 表达式参数说明实用性的案例 四、Scheduled注意事项五、配置文件1、fixedDelay2、fixedRate3、cron 一、基本使用 Scheduled // 由Spring定义&#xff0c;用于将方法设置为调度任务。…...

Xshell+screen解决ssh连接 服务器掉线的问题

Linux screen命令解决SSH远程服务器训练代码断开连接后运行中断_linux screen ssh-CSDN博客 Linux命令之screen命令_linux screen_恒悦sunsite的博客-CSDN博客 使用教程&#xff1a; 这里粗略介绍一下 &#xff08;1&#xff09;xshell xftp&#xff08;xshell点这个&#…...

coding_v3

面试经典 150 题 - 学习计划 - 力扣&#xff08;LeetCode&#xff09;全球极客挚爱的技术成长平台 数组/字符串 1.LC88【合并两个有序数组】 def solve(nums1, m, nums2, n):p1, p2 m-1, n-1tail m n -1while p1 > 0 or p2 > 0:if p1 -1:nums1[tail] nums2[p2]p2…...

Elasticsearch:什么是余弦相似度?

余弦相似度是数据科学、文本分析和机器学习领域的基本概念。 如果你想知道什么是余弦相似度或者它如何在现实世界的应用程序中使用&#xff0c;那么你来对地方了。 本指南旨在让你深入了解相似性是什么、其数学基础、优点及其在不同领域的各种应用。读完本指南后&#xff0c;你…...

【每日一题Day352】LC1726同积元组 | 哈希表+排列组合

同积元组【LC1726】 给你一个由 不同 正整数组成的数组 nums &#xff0c;请你返回满足 a * b c * d 的元组 (a, b, c, d) 的数量。其中 a、b、c 和 d 都是 nums 中的元素&#xff0c;且 a ! b ! c ! d 。 思路 求出所有二元组的积及其出现次数&#xff0c;假设某个积出现的次…...

react中在js文件里定义的变量,如何在less文件里去使用该变量

在 React 中&#xff0c;如果在 JS 文件中定义了变量&#xff0c;可以使用 CSS Modules 的方式将变量导出到 LESS 文件中。 以下是示例代码&#xff1a; // index.js import React from react; import styles from ./styles.module.less;const color red;function App() {re…...

TIA博途中通过SCATTER指令实现将字节BYTE拆分成单个位的具体方法示例

TIA博途中通过SCATTER指令实现将字节BYTE拆分成单个位的具体方法示例 例如: 我们想判断某个字节中各个位的状态是1还是0 ,如何实现呢? 这里介绍通过SCATTER指令拆分字节的方法,仅供大家参考。 首先,我们先了解以下SCATTER指令的基本功能和使用方法: 如下图所示,在基本指…...

网络协议--ARP:地址解析协议

4.1 引言 本章我们要讨论的问题是只对TCP/IP协议簇有意义的IP地址。数据链路如以太网或令牌环网都有自己的寻址机制&#xff08;常常为48 bit地址&#xff09;&#xff0c;这是使用数据链路的任何网络层都必须遵从的。一个网络如以太网可以同时被不同的网络层使用。例如&#…...

pdf导出实例(itestpdf)

依赖 <!-- https://mvnrepository.com/artifact/com.itextpdf/itextpdf --><dependency><groupId>com.itextpdf</groupId><artifactId>itextpdf</artifactId><version>5.5.10</version></dependency>工具类 package or…...

VCS编译选项+vcs+initreg+random实战:一个UVM测试平台的完整配置与效果验证

VCS编译选项vcsinitregrandom实战&#xff1a;UVM测试平台的高级配置与验证策略 在芯片验证领域&#xff0c;仿真初始状态的确定性直接影响测试结果的可信度。想象一下这样的场景&#xff1a;当你精心设计的UVM测试平台在回归测试中突然出现不一致的行为&#xff0c;而问题根源…...

别再折腾WSL了!用Docker Desktop 5分钟在Windows上跑通CP2K 2025.1

5分钟在Windows上部署CP2K 2025.1&#xff1a;Docker方案全指南 对于计算化学和材料科学领域的研究者来说&#xff0c;CP2K作为一款强大的原子模拟软件包&#xff0c;其功能覆盖从量子化学计算到分子动力学模拟的广泛场景。然而&#xff0c;传统在Windows系统上部署CP2K往往需…...

SteamCleaner终极指南:3步快速释放游戏缓存,轻松回收硬盘空间

SteamCleaner终极指南&#xff1a;3步快速释放游戏缓存&#xff0c;轻松回收硬盘空间 【免费下载链接】SteamCleaner :us: A PC utility for restoring disk space from various game clients like Origin, Steam, Uplay, Battle.net, GoG and Nexon :us: 项目地址: https://…...

别再纠结SysTick优先级了!聊聊FreeRTOS里那些‘不准’的时钟和软件定时器到底该怎么用

嵌入式实战&#xff1a;如何正确理解RTOS时钟精度与定时器设计哲学 在嵌入式开发领域&#xff0c;对实时操作系统(RTOS)时钟精度的追求常常成为开发者的一种执念。我们习惯性地认为"实时"就意味着"精确到微秒"&#xff0c;这种完美主义倾向在实际项目中往往…...

为什么Adobe GenP 3.0成为创意工作者的数字工具箱钥匙?

为什么Adobe GenP 3.0成为创意工作者的数字工具箱钥匙&#xff1f; 【免费下载链接】Adobe-GenP Adobe CC 2019/2020/2021/2022/2023 GenP Universal Patch 3.0 项目地址: https://gitcode.com/gh_mirrors/ad/Adobe-GenP 在数字创意领域&#xff0c;Adobe Creative Clou…...

IUV全网元协同排障实战:从无线侧到核心网的典型配置错点解析

1. 从"用户无法接入5G网络"说起&#xff1a;一个典型故障的排查起点 上周遇到个挺有意思的案例&#xff1a;某运营商新建的5G SA网络完成部署后&#xff0c;测试终端始终显示"无服务"状态。这个看似简单的现象背后&#xff0c;其实藏着从无线侧到核心网可能…...

STM32无源蜂鸣器进阶玩法:基于MIDI协议的音乐播放器设计与实现

STM32无源蜂鸣器进阶玩法&#xff1a;基于MIDI协议的音乐播放器设计与实现 在嵌入式开发中&#xff0c;让硬件"唱出"动听旋律总是一件令人兴奋的事情。不同于简单的固定曲目播放&#xff0c;基于MIDI协议的音乐播放系统为STM32开发者提供了更专业的音频控制方式。本文…...

物候相机、无人机、通量塔...我的物候观测验证“全家桶”搭建与踩坑实录

物候观测技术实战&#xff1a;从地面相机到无人机的多尺度验证体系搭建 清晨六点&#xff0c;当第一缕阳光穿透森林冠层时&#xff0c;物候相机已经自动捕捉了三十张不同光谱波段的植被影像。与此同时&#xff0c;三公里外的通量塔正在记录着二氧化碳交换速率的细微变化&#x…...

别只刷题了!这道PTA列车调度题,藏着STL set在真实项目里的妙用

从PTA列车调度到工业级资源管理&#xff1a;STL set的实战智慧 当游戏服务器需要为数千名玩家快速分配空闲资源时&#xff0c;当数据库连接池要高效管理有限连接时&#xff0c;这些看似复杂的系统问题&#xff0c;竟与PTA那道经典的列车调度题目有着惊人的相似内核。本文将带您…...

MAA明日方舟助手:终极自动化攻略,彻底解放你的游戏时间

MAA明日方舟助手&#xff1a;终极自动化攻略&#xff0c;彻底解放你的游戏时间 【免费下载链接】MaaAssistantArknights 《明日方舟》小助手&#xff0c;全日常一键长草&#xff01;| A one-click tool for the daily tasks of Arknights, supporting all clients. 项目地址:…...