我们有一个系统，它公开了一个http端点，该端点触发一些内部操作，并向kafka队列异步发送消息。我们希望在输入是http请求而预期输出是发布到队列的消息的情况下度量性能。我们正在评估jmeter是否是这种测量的正确工具。虽然http请求是微不足道的，但kafka侦听器根本不是。有没有办法配置/扩展jmeter来读取来自特定主题的消息并（理想情况下）对其进行Assert？
vi4fp9gy1#
看看用java编写kafka消费者文章，它解释了如何连接到kafka主题并使用java代码读取消息。关于jmeter，假设您在jmeter类路径下有kafka客户机库（具有所有依赖项），您应该能够在jsr223 sampler中重用javakafka消费者代码如有需要，请参阅ApacheKafka-HowtoLoadTestwithJMeter文章以获得更详细的说明
1条答案
按热度按时间vi4fp9gy1#
看看用java编写kafka消费者文章，它解释了如何连接到kafka主题并使用java代码读取消息。
关于jmeter，假设您在jmeter类路径下有kafka客户机库（具有所有依赖项），您应该能够在jsr223 sampler中重用javakafka消费者代码
如有需要，请参阅ApacheKafka-HowtoLoadTestwithJMeter文章以获得更详细的说明