diff --git a/modules/beam/src/main/scala/com.snowplowanalytics.snowplow.enrich.beam/Enrich.scala b/modules/beam/src/main/scala/com.snowplowanalytics.snowplow.enrich.beam/Enrich.scala
index b846f1e8f..d67944530 100644
--- a/modules/beam/src/main/scala/com.snowplowanalytics.snowplow.enrich.beam/Enrich.scala
+++ b/modules/beam/src/main/scala/com.snowplowanalytics.snowplow.enrich.beam/Enrich.scala
@@ -55,7 +55,8 @@ object Enrich {
   implicit val badRowScioCodec: Coder[BadRow] = Coder.kryo[BadRow]
 
   // the maximum record size in Google PubSub is 10Mb
-  private val MaxRecordSize = 10000000
+  // the maximum PubSubIO size is 7Mb to overcome base64-encoding
+  private val MaxRecordSize = 6900000
   private val MetricsNamespace = "snowplow"
 
   val enrichedEventSizeDistribution =