负载测试卡夫卡使用者

Question

(我正在编辑这个问题，因为我认为它不够清楚)

我如何加载测试我的卡夫卡消费者？我已经看过很多关于负载测试的文章，apache，但是没有关于负载测试的文章。为了前夫。我在jsr223上写了“千兆卡夫卡制作人测试计划”，把事件发送给卡夫卡主题。我的卡夫卡弹簧引导消费者听这个主题，消费事件，并开始处理它。杰米只是向我展示了关于制片人的报道，仅此而已。有没有更好的方法来加载测试春季启动卡夫卡消费者应用程序并得到报告？从消耗时间到过程的结束？

Answer 1

我相信kafka-consumer-perf-test.sh脚本适用于每一个卡夫卡安装，对于您的用例来说，它应该足够了，有关更多细节，请参见性能测试Kafka Wiki页面。

该脚本可以使用JMeter与OS进程采样器集成

如果您说的是使用JMeter从断断续续中读取消息--这可以由任何JSR223测试元件完成

1. 获得Kafka Java客户端
2. 将库和依赖项一起放入JMeter类路径中
3. 重新启动JMeter以获取库
4. 将实现从Kafka主题中读取消息的代码放入JSR223示例片段中： (‘props.put(’bootstrap.server‘，'192.168.99.100:9092') props.put(’group.id p.id‘，'foo') props.put('enable.auto.commit'，'true') props.put(’auto.Comm.interval.ms‘，'1000') props.put('session.timeout.ms'，'30000') props.put(’key.deseriizer‘，’props.put props.put‘(’#en0#e.deseriizer‘)，'org.apache.kafka.common.serialization.StringDeserializer') def使用者=新的org.apache.kafka.clients.consumer.KafkaConsumer(props) def String>= 'sometopic‘consumer.subscribe(Arrays.asList(主题))log.info(“订阅了主题”+主题)而(true) { def records = consumer.poll(100) records.each { record -> log.info('Received：’+ record.value()) }}

更多信息：

• Apache如何使用JMeter加载测试