Index: build.sbt
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
diff --git a/build.sbt b/build.sbt
--- a/build.sbt	(revision 1fdebaf338c3fa9f6e97c13721867876ef3be565)
+++ b/build.sbt	(revision d2cd298ebaaf6b8ab8ed48fcbfa176adfb99eb0f)
@@ -7,7 +7,7 @@
 scalaVersion := "2.12.10"
 
 libraryDependencies ++= Seq(
-  "io.gatling" % "gatling-core" % "3.3.1" % "provided",
+  "io.gatling" % "gatling-core" % "3.4.2" % "provided",
   ("org.apache.kafka" % "kafka-clients" % "2.4.0")
     // Gatling contains slf4j-api
     .exclude("org.slf4j", "slf4j-api")
Index: src/main/scala/com/github/mnogu/gatling/kafka/action/KafkaRequestAction.scala
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
diff --git a/src/main/scala/com/github/mnogu/gatling/kafka/action/KafkaRequestAction.scala b/src/main/scala/com/github/mnogu/gatling/kafka/action/KafkaRequestAction.scala
--- a/src/main/scala/com/github/mnogu/gatling/kafka/action/KafkaRequestAction.scala	(revision 1fdebaf338c3fa9f6e97c13721867876ef3be565)
+++ b/src/main/scala/com/github/mnogu/gatling/kafka/action/KafkaRequestAction.scala	(revision d2cd298ebaaf6b8ab8ed48fcbfa176adfb99eb0f)
@@ -9,7 +9,6 @@
 import io.gatling.commons.validation.Validation
 import io.gatling.core.CoreComponents
 import io.gatling.core.util.NameGen
-import io.gatling.core.stats.message.ResponseTimings
 import org.apache.kafka.clients.producer._
 
 
@@ -39,7 +38,7 @@
 
       outcome.onFailure(
         errorMessage =>
-          statsEngine.reportUnbuildableRequest(session, requestName, errorMessage)
+          statsEngine.reportUnbuildableRequest(session.scenario,  List.empty, requestName, errorMessage)
       )
 
       outcome
@@ -71,7 +70,8 @@
 
           val requestEndDate = clock.nowMillis
           statsEngine.logResponse(
-            session,
+            session.scenario,
+            List.empty,
             requestName,
             startTimestamp = requestStartDate,
             endTimestamp = requestEndDate,
@@ -81,7 +81,7 @@
           )
 
           if (throttled) {
-            coreComponents.throttler.throttle(session.scenario, () => next ! session)
+            coreComponents.throttler.get.throttle(session.scenario, () => next ! session)
           } else {
             next ! session
           }
Index: src/main/scala/com/github/mnogu/gatling/kafka/protocol/KafkaComponents.scala
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
diff --git a/src/main/scala/com/github/mnogu/gatling/kafka/protocol/KafkaComponents.scala b/src/main/scala/com/github/mnogu/gatling/kafka/protocol/KafkaComponents.scala
--- a/src/main/scala/com/github/mnogu/gatling/kafka/protocol/KafkaComponents.scala	(revision 1fdebaf338c3fa9f6e97c13721867876ef3be565)
+++ b/src/main/scala/com/github/mnogu/gatling/kafka/protocol/KafkaComponents.scala	(revision d2cd298ebaaf6b8ab8ed48fcbfa176adfb99eb0f)
@@ -6,7 +6,7 @@
 
 case class KafkaComponents(kafkaProtocol: KafkaProtocol) extends ProtocolComponents {
 
-  override def onStart: Session => Session = ProtocolComponents.NoopOnStart
+  override def onStart: Session => Session = Session.Identity
 
   override def onExit: Session => Unit = ProtocolComponents.NoopOnExit