我有一个Kafka模拟测试使用加特林和目前我们能够运行与康斯坦图塞尔珀塞克在给定的时间。但是我们想在constantuserspersec上运行这个模拟(比如说大约1000/秒),这个测试应该一直运行,直到有人杀死这个测试/进程。
目前,我们已调整为使用天数代替工期。但是有没有一个选项可以永远运行一个使用feeder的测试呢。以下是代码片段:
val scn = scenario("Kafka Test Demo")
.feed(ssv(conf.getString("filename"), true).circular)
.exec(kafka("request")
// message to send
.send[String]("${t}"))
setUp(
scn.inject(constantUsersPerSec(conf.getInt("constantUsersPerSec")) during (conf.getInt("run_duration_in_mins") hours)))
.protocols(kafkaConf)
有什么建议/指示吗?
非常感谢,玛莎
1条答案
按热度按时间pvabu6sv1#
贝娄密码有用吗?