// Acerca de
Plugin del protocolo Kafka para Gatling. Flujos produce-only y request-reply con serialización simple, helpers de Avro4s e integración con Schema Registry. La correlación de respuestas se configura a nivel de protocolo y la sigue un consumer compartido.
// Destacado
- Produce-only mediante kafka("name").topic(...).send(...)
- Request-reply con correlación matchByValue / matchByMessage
- Avro4s + Schema Registry, o tu propio Kafka Serde[T]
- Gatling 3.13.5 · Scala 2.13.16 · Java 17+
// build.sbt
libraryDependencies += "org.galaxio" %% "gatling-kafka-plugin" % "<version>" % Test
import org.galaxio.gatling.kafka.Predef._
import io.gatling.core.Predef._
val kafkaConf = kafka
.properties(Map("bootstrap.servers" -> "localhost:9092"))
val scn = scenario("Kafka Producer")
.exec(
kafka("send message")
.topic("test-topic")
.send[String, String]("key", """{"msg": "hello"}""")
)
setUp(scn.inject(atOnceUsers(1))).protocols(kafkaConf)