我是Kafka的新人。我已经用springboot编写了一个kafka消费者应用程序。此应用程序使用来自kafka的消息，对其进行处理并存储在db中。
现在，我想为这个消费者应用程序编写性能测试。这个测试应该告诉我消费者应用程序的性能，比如在特定负载下处理消息需要多少时间。
我之前已经使用gatling编写了性能测试，我们有端点。但是在这个应用程序中，我没有任何rest端点。所以，如果我知道如何做这个应用程序或任何指针性能测试将不胜感激。
我是Kafka的新人。我已经用springboot编写了一个kafka消费者应用程序。此应用程序使用来自kafka的消息，对其进行处理并存储在db中。
现在，我想为这个消费者应用程序编写性能测试。这个测试应该告诉我消费者应用程序的性能，比如在特定负载下处理消息需要多少时间。
我之前已经使用gatling编写了性能测试，我们有端点。但是在这个应用程序中，我没有任何rest端点。所以，如果我知道如何做这个应用程序或任何指针性能测试将不胜感激。
2条答案
按热度按时间r8uurelv1#
你可以用
kafka-consumer-perf-test.sh用Kafka Package 的剧本。您可以指定要读取的消息数、处理线程数和任何常用的使用者配置。该工具将输出消耗的数据量和吞吐量以及其他指标。qf9go6mv2#
您基本上需要将消息发布到kafka队列并测量它们被应用程序处理的速度，任何适合这样做的工具都适合。
例如
kafka-console-producer每个Kafka发行版都有剧本。如果你和盖特林很好，你可以使用盖特林Kafka插件。
ApacheJMeter还有一个PepperBox-kafka负载生成器插件，这样您就不必编写一行代码了。如果需要，请参阅ApacheKafka-HowtoLoadTestwithJMeter文章以获取更多详细信息。