Hi all,
I’m trying to create a gatling test that performs a REST POST and Produce a Kafka message.
I need this to test performance of the system, and to more accurate results I need to create a post and complete the job with a kafka message.
`
val startOrder = 30000000
`
`
val endOrder = 40000000
def OrderId() = {
val r = ThreadLocalRandom.current().nextInt(startOrder, endOrder)
}
val post = {
exec(http(“OrderUpload”)
.post(“/Orders”)
.body(StringBody( session =>
s"“”
{
“OrderId”: “${OrderId()}”,
}
“”".stripMargin)).asJson)
}
val produce = {
exec(
kafka(“request”)
.send(StringBody( session =>
s"“”
{ |
“CheckoutOrderId”: “${OrderId()}”,
}
“”"
.stripMargin)))
}
}
val scn1 = scenario(“OrderUpload”).exec(OrderUpload.produce, OrderUpload.post)
setUp(
scn1.inject(constantUsersPerSec(1) during(1 seconds)).protocols(httpProtocol, kafkaConf),
)
`
Does any one can give me a tip how can I perform this?
What is happening is each request is calculating it’s order id