pubsub sink: wrap bytes instead of copying (close #28)

snowplow-incubator · Nov 20, 2023 · da14e58 · da14e58
1 parent 810450b
commit da14e58
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/modules/pubsub/src/main/scala/com/snowplowanalytics/snowplow/sinks/pubsub/PubsubSink.scala b/modules/pubsub/src/main/scala/com/snowplowanalytics/snowplow/sinks/pubsub/PubsubSink.scala
@@ -37,7 +37,7 @@ object PubsubSink {
         for {
           uuid <- Async[F].delay(UUID.randomUUID)
           message = PubsubMessage.newBuilder
-                      .setData(ByteString.copyFrom(bytes))
+                      .setData(ByteString.wrap(bytes))
                       .setMessageId(uuid.toString)
                       .putAllAttributes(attributes.asJava)
                       .build