项目测试服务消费Kafka能力,需要消费特定格式的数据,因此要向Kafka中灌入数据,给老铁们分享下jmeter向kafka发送数据方法:
1. 首先在jmeter如下目录中导入一个kafka相关的jar包,如图:
2. 导入之后就可以打开JMeter进行操作了,首先在线程组中添加一个java请求:
在java请求中Class name选择kafkaProducerSampler中,然后配置好Kafka的相关参数:
kafka_brokers:kafka地址
kafka_topic:传入的主题
kafka_key:用于标识消息的逻辑关联关系
kafka_message:要发送的数据
kafka_message_serializer:在Kafka中,消息序列化器(Message Serializer)是一个关键的组件,它负责将消息对象转换为字节数组,以便在网络上传输或存储在Kafka的日志文件中。同样地,反序列化器(Deserializer)则负责将字节数组转换回原始的消息对象。
3.在线程组中配置线程数、循环次数(想要灌入多少数据就配置循环就好)
运行测试计划就可以使用JMeter往Kafka中发送数据
借助kakfa tool就可以在传数的主题下看到通过jmeter发送过来的数据
最后感谢每一个认真阅读我文章的人,礼尚往来总是要有的,虽然不是什么很值钱的东西,如果你用得到的话可以直接拿走:【文末自行领取】
这些资料,对于【软件测试】的朋友来说应该是最全面最完整的备战仓库,这个仓库也陪伴上万个测试工程师们走过最艰难的路程,希望也能帮助到你!