gatling-kafka-plugin

gatling-kafka-plugin copied to clipboard

## About this PR 📦 Updates [org.scala-sbt:sbt](https://github.com/sbt/sbt) from `1.8.2` to `1.8.3` 📜 [GitHub Release Notes](https://github.com/sbt/sbt/releases/tag/v1.8.3) - [Version Diff](https://github.com/sbt/sbt/compare/v1.8.2...v1.8.3) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...

scala-steward

With the current solution, it is only possible to match between produced and consumed event. I have the problem that I would like to extract some information from the successfully...

DevArosan

Add the possibility to match producer and consumed messages using headers instead of just using the message Key.

6

With the current solution, it is only possible to match producer and consumed messages using the key from the sent message. However, in our project, we have an internal key...

mmartin-paxos

I am getting this error when i am running the test with more than 40 request per second for at leat 40second. ---- Errors -------------------------------------------------------------------- > producedData-to-kafka: Failed to build...

parimaljanagithub

Double nested Classes are not compatible with Java

4

With the current Implementation, the plugin is not compatible with Java even though Gatling provides multiple compatibilities with Scala/Java/Kotlin. Therefore to make it Java compatible it is needed to apply...

mmartin-paxos

Kafka message key is None

1

Пример отправки сообщения exec( kafka("Some kafka message with header") .send( None, "some payload", new RecordHeaders().add("headerKey", "headerValue".getBytes) ) ) Ожидается, что в кафку отправиться сообщение с ключём null, а отправляется None...

primko

Support Avro classes in ReqRep

1

In the default `Kafka.send` method it is possible to use Avro Java classes (generated by avro-maven-plugin) as payload in key or value. The payload then gets serialized as valid Avro...

neoscaler

Scenario / Runner doesn't shut down

1

I'm running [your example](https://github.com/Tinkoff/gatling-kafka-plugin/blob/master/src/test/scala/ru/tinkoff/gatling/kafka/examples/GatlingRunner.scala) but the process doesn't shut down. Log: ``` Simulation simulations.BasicSimulation started... 17:26:06.173 [WARN ] o.a.k.s.i.m.ClientMetrics - Error while loading kafka-streams-version.properties java.lang.NullPointerException: inStream parameter is null at...

simonstratmann

Using session attributes inside the avro object builder

2

Hi there, Could you please add the ability to use session attributes in the avro object builder. For example, I use this code ``` exec( _.set("text", "Hello")) .exec( kafka("incomeMsg") .send("myTopic",...

s-danilov