diff --git a/src/Transports/GCP/Wolverine.Pubsub/Internal/PubsubEnvelopeMapper.cs b/src/Transports/GCP/Wolverine.Pubsub/Internal/PubsubEnvelopeMapper.cs index caddd7df..f63ec2ba 100644 --- a/src/Transports/GCP/Wolverine.Pubsub/Internal/PubsubEnvelopeMapper.cs +++ b/src/Transports/GCP/Wolverine.Pubsub/Internal/PubsubEnvelopeMapper.cs @@ -47,7 +47,7 @@ public void MapOutgoingToMessage(OutgoingMessageBatch outgoing, PubsubMessage me { message.Data = ByteString.CopyFrom(outgoing.Data); message.Attributes["destination"] = outgoing.Destination.ToString(); - message.Attributes["batched"] = string.Empty; + message.Attributes["batched"] = "1"; } protected override void writeOutgoingHeader(PubsubMessage outgoing, string key, string value)