diff --git a/README.md b/README.md
index 8be8ce2..dc3c486 100644
--- a/README.md
+++ b/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:
diff --git a/build.sbt b/build.sbt
index 76e578c..726772b 100644
--- a/build.sbt
+++ b/build.sbt
@@ -1,6 +1,6 @@
 name := "gatling-kafka"
 
-version := "3.3"
+version := "3.4"
 
 scalaVersion := "2.13.12"
 
diff --git a/changelog.txt b/changelog.txt
index 2e87d99..ed87a01 100644
--- a/changelog.txt
+++ b/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
diff --git a/src/main/scala/io/github/amerousful/kafka/client/KafkaTrackerPoll.scala b/src/main/scala/io/github/amerousful/kafka/client/KafkaTrackerPoll.scala
index e97d3aa..28a4a45 100644
--- a/src/main/scala/io/github/amerousful/kafka/client/KafkaTrackerPoll.scala
+++ b/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}
diff --git a/src/main/scala/io/github/amerousful/kafka/client/WaitRebalancing.scala b/src/main/scala/io/github/amerousful/kafka/client/WaitRebalancing.scala
index 3e84ae6..61e0f11 100644
--- a/src/main/scala/io/github/amerousful/kafka/client/WaitRebalancing.scala
+++ b/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()
   }