如何为kafka消费者java应用程序编写性能测试？

Question

我是卡夫卡的新手。我使用spring boot编写了一个kafka消费者应用程序。此应用程序使用来自kafka的消息，处理它并存储在DB中。

现在，我想为这个消费者应用程序编写性能测试。这个测试应该告诉我我的消费者应用程序的性能，比如在一定负载下处理消息需要多长时间。

我之前使用Gatling编写了性能测试，我们有端点。但在这个应用程序中，我没有任何休息端点。所以，如果我知道如何为这个应用程序进行性能测试或任何指针将不胜感激。

Answer 1

您基本上需要将消息发布到Kafka队列并测量应用程序处理它们的速度，任何适合这样做的工具都适合。

1. 例如，kafka-console-producer script附带每个kafka发行版。
2. 如果你对Gatling很好，你可以使用Gatling-Kafka插件。
3. Pepper-Box - Kafka Load Generator还有Apache JMeter插件，这样你就不必编写一行代码了。如果需要，请查看Apache Kafka - How to Load Test with JMeter文章了解更多详情。

Answer 2

您可以使用与Kafka一起打包的kafka-consumer-perf-test.sh脚本。您可以指定要读取的消息数，处理线程数和任何常用的consumer configurations。该工具将输出所消耗的数据量和其他指标之间的吞吐量。