2016-02-08 34 views
0

我使用Gatling进行了kafka模拟测试,目前我们可以在给定的持续时间内使用constantUsersPerSec运行。但我们想在constantUsersPerSec上运行这个模拟(比如说大约1000 /秒),这个测试应该一直运行,直到有人杀死测试/进程。使用Feed永远加特林测试

目前我们已经调整为使用天数来代替持续时间。但是有没有一个选项可以永远运行一个使用馈线的测试。这里是代码片段:

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) 

任何建议/方向请吗?

千恩万谢, MPHA

回答

0

是代码波纹管去上班?

val scn = scenario("Kafka Test Demo") 
    .feed(ssv(conf.getString("filename"), true)).circular.forever() { 
    exec(kafka("request") 
    // message to send 
    .send[String]("${t}")) 
} 
+0

我试着用上面的代码片段运行,但它运行的时候没有发布任何消息到主题。做我需要做下面的代码的任何改变,因为我在注射期间设置,它不会被永远告诉并通过时间任何意义:设置( scn.inject(constantUsersPerSec(conf.getInt(“constantUsersPerSec” ))期间(conf.getInt(“run_duration_in_mins”)小时))) .protocols(kafkaConf) – user1459742

+0

此外上面的代码工作,但它不会持续发送请求的相同的负载,例如说我们想送1000 REQ /秒,那么一会儿它将是1000,然后它可以随机跳到我们不确定的任何值。 – user1459742