首页 > 其他分享 >【kafka】Kafka压力测试

【kafka】Kafka压力测试

时间:2023-11-10 18:22:19浏览次数:34  
标签:perf producer -- kafka sh 测试 test Kafka

kafka 自带的压测工具 kafka-producer-perf-test.sh 和 kafka-consumer-perf-test.sh

./bin/kafka-producer-perf-test.sh --topic kafka-test --num-records 10000 --record-size 1024 --throughput -1 --producer-props bootstrap.servers=10.206.16.18:9092 compression.type=lz4

./bin/kafka-consumer-perf-test.sh --broker-list 10.206.16.18:9092 --topic kafka-test --messages 10000000 --threads 8 --reporting-interval 1000

参考:
https://blog.csdn.net/hyunbar/article/details/106991455

标签:perf,producer,--,kafka,sh,测试,test,Kafka
From: https://www.cnblogs.com/aaacarrot/p/17824773.html

相关文章

  • RVS—面向目标硬件的软件性能测试工具
    产品概述    RapitaVerificationSuite(简称:RVS),为美国Danlaw公司提供的一款嵌入式系统在板测试套件,主要应用于汽车领域。其产品符合ISO-26262、DO178B/C、IEC-61508等行业标准,兼容Vxworks、Linux、SYSBIOS等操作系统,支持C、C++、Ada多种语言,多方位支撑TI、IBM、Intel、ARM......
  • 软件测试|web自动化测试神器playwright教程(三十八)
    简介在我们使用selenium时,我们可以获取元素的属性,元素的文本值,以及输入框的内容等,作为比selenium更为强大的web自动化测试神器,playwright也可以实现对元素属性,文本值和输入框内容的抓取,并且实现比selenium更为简单,本文我们就为大家介绍一下使用playwright获取元素属性,元素文本值以......
  • 软件测试|解决Github port 443 : Timed out连接超时的问题
    前言GitHub是全球最大的开源代码托管平台之一,许多开发者和团队使用它来管理和协作开源项目。但在当下,我们在clone或者提交代码时会经常遇到"GitHubPort443:TimedOut"错误,这意味着我们的电脑无法建立与GitHub服务器的安全连接。这个问题通常由网络问题或防火墙设置引起。在本文......
  • 怎么使用Kafka?收藏这篇短文就可以了
    〇、前言便于大家对本章内容的理解,我重新整理了一下Kafka中的部分重要概念,以表格的方式呈现出来,请见下表所示:名词解释Broker节点一个Kafka节点就是一个Broker,一个和多个Broker可以组成一个Kafka集群Topic主题Kafka根据topic对消息进行归类,发布到kafka集群的每套消息都需要指定一......
  • tidb数据库5.4.3和6.5.3版本性能测试对比
    作者:qizhining一、测试需求:基于历史原因,我们的业务数据库一直使用5.4.3,最近由于研发提出需求:需要升级到6.5.3版本,基于版本不同,需要做个压力测试已验证2个版本之间的性能差异。二、测试目的:验证tidb数据库5.4.3和6.5.3版本性能的差异三、测试结果:tidb数据库6.5.3版本比5.4.3总体性......
  • kafka复习:(2)客户端发送消息并异步处理返回结果
    packagecom.cisdi.dsp.modules.metaAnalysis.rest.kafka2023;importorg.apache.kafka.clients.producer.*;importorg.apache.kafka.common.serialization.StringSerializer;importjava.time.Duration;importjava.util.Properties;importjava.util.concurrent.E......
  • Kafka入门
    Kafka定义Kafka是一个分布式的流处理平台,它具有以下特性:磁盘保存数据伸缩性术语生产者生产者是消息的创造者,可以指定Topic,Partion,Key,Value,并将消息发送到Kafka集群中的Broker。消费者消费者负责从Kafka集群中读取消息。需要设置偏移量一个分区里面,每个消息的偏移......
  • Kafka JNDI 注入分析(CVE-2023-25194)
    ApacheKafkaClientsJndiInjection漏洞描述ApacheKafka是一个分布式数据流处理平台,可以实时发布、订阅、存储和处理数据流。KafkaConnect是一种用于在kafka和其他系统之间可扩展、可靠的流式传输数据的工具。攻击者可以利用基于SASLJAAS配置和SASL协议的任意Kafka......
  • Kafka队列
    ......
  • Apache JMeter压力测试工具使用
    JMeter是Apache组织开发的基于Java的压力测试工具,用于对软件做压力测试。软件下载下载地址:https://jmeter.apache.org/download_jmeter.cgi最新版本5.6.2用浏览器下载发现慢得很,用迅雷下载非常快哟。测试使用在使用前需要先安装jdk下载完后将文件解压缩,找到bin目录下的jmeter.b......