From 50e45d05900f0fea23cf76961ef78307ee904323 Mon Sep 17 00:00:00 2001 From: Muneyuki Noguchi <nogu.dev@gmail.com> Date: Wed, 23 Dec 2015 16:22:17 +0900 Subject: [PATCH] Add comments to the simulation file. --- .../mnogu/gatling/kafka/test/BasicSimulation.scala | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/test/scala/com/github/mnogu/gatling/kafka/test/BasicSimulation.scala b/src/test/scala/com/github/mnogu/gatling/kafka/test/BasicSimulation.scala index e99f7d2..e1446ae 100644 --- a/src/test/scala/com/github/mnogu/gatling/kafka/test/BasicSimulation.scala +++ b/src/test/scala/com/github/mnogu/gatling/kafka/test/BasicSimulation.scala @@ -8,18 +8,26 @@ import com.github.mnogu.gatling.kafka.Predef._ class BasicSimulation extends Simulation { val kafkaConf = kafka + // Kafka topic name .topic("test") + // Kafka producer configs .properties( Map( ProducerConfig.ACKS_CONFIG -> "1", + // list of Kafka broker hostname and port pairs ProducerConfig.BOOTSTRAP_SERVERS_CONFIG -> "localhost:9092", + + // in most cases, StringSerializer or ByteArraySerializer ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG -> "org.apache.kafka.common.serialization.StringSerializer", ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG -> "org.apache.kafka.common.serialization.StringSerializer")) val scn = scenario("Kafka Test") - .exec(kafka("request").send[String]("foo")) + .exec( + kafka("request") + // message to send + .send[String]("foo")) setUp( scn