Update the simulation file to avoid exceptions.

mnogu · Dec 23, 2015 · 1afb2d4 · 1afb2d4
1 parent e251885
commit 1afb2d4
Showing 1 changed file with 3 additions and 3 deletions.
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
@@ -14,12 +14,12 @@ class BasicSimulation extends Simulation {
         ProducerConfig.ACKS_CONFIG -> "1",
         ProducerConfig.BOOTSTRAP_SERVERS_CONFIG -> "localhost:9092",
         ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG ->
-          "org.apache.kafka.common.serialization.ByteArraySerializer",
+          "org.apache.kafka.common.serialization.StringSerializer",
         ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG ->
-          "org.apache.kafka.clients.producer.ByteArraySerializer"))
+          "org.apache.kafka.clients.producer.StringSerializer"))
 
   val scn = scenario("Kafka Test")
-    .exec(kafka("request").send("foo"))
+    .exec(kafka("request").send[String]("foo"))
   // You can also use feeder
   //
   //val scn = scenario("Kafka Test")