我们的系统接受post请求，并将json主体发送到kafka主题，该主题被配置为pout进行拓扑，拓扑生成输出消息到一个kafka主题。如何对这个系统进行负载测试？系统每秒处理的消息数。我计划使用jmeter进行负载测试
5hcedyr01#
每当我们想到webapi的性能或负载测试时，jmeter就会出现在我们的脑海中，但是您也可以检查loadrunner等替代方法。但是，从kafka和storm的Angular 来看，您需要编写storm kafka-spout来读取和提交偏移量，还可能需要一些监视工具来检查和验证它在类似负载的情况下的行为数据大小的吞吐量（消息/秒）。消息数的吞吐量（消息/秒）。制片方业绩用户端性能我试过yahoo kafka manager，它是开源的，可以满足我的需求，我想试试：https://github.com/yahoo/kafka-manager然而，Kafka的监控工具在生产中也有其他的监控工具如果您只想关注kafka负载性能基准测试，那么kafka发行版下的以下命令将非常有用：kafka-producer-perf-test.sh文件kafka-consumer-perf-test.sh有关详细信息：https://gist.github.com/ueokande/b96eadd798fff852551b80962862bfb3
5jvtdoz22#
如果您计划使用jmeter，那么考虑PepperBox-kafka load generator插件是有意义的，它附带了pepperboxkafkasampler，它提供了方便的ui，允许您指定kafka端点、主题等。如果您还需要阅读来自kafka主题的消息，您可以使用jsr223测试元素和groovy语言来实现这一点，请查看apache kafka-如何使用jmeter加载测试和在java文章中编写kafka使用者以获取更多信息和示例代码段
2条答案
按热度按时间5hcedyr01#
每当我们想到webapi的性能或负载测试时，jmeter就会出现在我们的脑海中，但是您也可以检查loadrunner等替代方法。
但是，从kafka和storm的Angular 来看，您需要编写storm kafka-spout来读取和提交偏移量，还可能需要一些监视工具来检查和验证它在类似负载的情况下的行为
数据大小的吞吐量（消息/秒）。
消息数的吞吐量（消息/秒）。
制片方业绩
用户端性能
我试过yahoo kafka manager，它是开源的，可以满足我的需求，我想试试：https://github.com/yahoo/kafka-manager然而，Kafka的监控工具在生产中也有其他的监控工具
如果您只想关注kafka负载性能基准测试，那么kafka发行版下的以下命令将非常有用：
kafka-producer-perf-test.sh文件
kafka-consumer-perf-test.sh
有关详细信息：https://gist.github.com/ueokande/b96eadd798fff852551b80962862bfb3
5jvtdoz22#
如果您计划使用jmeter，那么考虑PepperBox-kafka load generator插件是有意义的，它附带了pepperboxkafkasampler，它提供了方便的ui，允许您指定kafka端点、主题等。
如果您还需要阅读来自kafka主题的消息，您可以使用jsr223测试元素和groovy语言来实现这一点，请查看apache kafka-如何使用jmeter加载测试和在java文章中编写kafka使用者以获取更多信息和示例代码段