// О продукте
Плагин протокола Kafka для Gatling. Сценарии produce-only и request-reply с обычной сериализацией, хелперами Avro4s и интеграцией со Schema Registry. Корреляция ответов настраивается на уровне протокола и отслеживается общим консьюмером.
// Ключевое
- Produce-only через kafka("name").topic(...).send(...)
- Request-reply с корреляцией matchByValue / matchByMessage
- Avro4s + Schema Registry или собственный 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)