gatling-kafka-plugin
gatling-kafka-plugin copied to clipboard
Define topic at sending time
Hi,
In my test I need to send messages to multiple kafka topics within one scenario. Is it possible at the moment? Currently I can see that you define the topic at the protocol building, but I'd like to be able to execute something like this:
private val scn = scenario("Basic")
.exec(kafka("BasicRequest").send("my-topic", "my-message"))
.exec(kafka("anotherRequest").send("my-other-topic", "custom-key", "12.0"))
I suggest anything related to the Kafka target cluster to be configurable dynamically rather than requiring hardcoding / statically binding in the Simulation.
This is equivalent to vanilla Gatling for which the target is not part of the simulation / scenario.
Any suggestion on how to work around the current limitation outside of statically loading from env / config file / hardcoding in each Simulation?