Version 3.4

README.md

@@ -11,7 +11,7 @@ Add to your `pom.xml`
 <dependency>
     <groupId>io.github.amerousful</groupId>
     <artifactId>gatling-kafka</artifactId>
-    <version>3.3</version>
+    <version>3.4</version>
 </dependency>
 ```
 
@@ -20,7 +20,7 @@ Add to your `pom.xml`
 Add to your `build.sbt`
 
 ```scala
-libraryDependencies += "io.github.amerousful" % "gatling-kafka" % "3.3"
+libraryDependencies += "io.github.amerousful" % "gatling-kafka" % "3.4"
 ```
 
 Import:

build.sbt

@@ -1,6 +1,6 @@
 name := "gatling-kafka"
 
-version := "3.3"
+version := "3.4"
 
 scalaVersion := "2.13.12"
 

changelog.txt

@@ -1,3 +1,7 @@
+Changelog 3.4 (02-08-2024)
+----------------------------
+* Fix. Remove `seekToEnd` after rebalancing
+
 Changelog 3.3 (01-08-2024)
 ----------------------------
 * Add the ability to override the `auto.offset.reset` and `enable.auto.commit` values in the TrackerPoll

src/main/scala/io/github/amerousful/kafka/client/KafkaTrackerPoll.scala

@@ -12,7 +12,6 @@ import io.gatling.core.util.NameGen
 import io.github.amerousful.kafka.action.KafkaLogging
 import io.github.amerousful.kafka.protocol.KafkaMatcher
 import io.github.amerousful.kafka.request.KafkaAttributes
-import org.apache.kafka.clients.producer.ProducerRecord
 import org.apache.kafka.common.serialization.StringDeserializer
 
 import java.util.concurrent.{ConcurrentHashMap, CountDownLatch}

src/main/scala/io/github/amerousful/kafka/client/WaitRebalancing.scala

@@ -12,7 +12,6 @@ case class WaitRebalancing(consumerName: String, callback: () => Unit) extends P
 
   override def onAssign(assignedTps: Set[TopicPartition], consumer: RestrictedConsumer): Unit = {
     logger.debug(s"Partitions [${assignedTps.mkString(", ")}] have been assigned for consumer [$consumerName]")
-    consumer.seekToEnd(assignedTps.asJava)
     callback()
   }