diff --git a/src/DotPulsar/Internal/ProducerStream.cs b/src/DotPulsar/Internal/ProducerStream.cs
index 839a681..a5827ca 100644
--- a/src/DotPulsar/Internal/ProducerStream.cs
+++ b/src/DotPulsar/Internal/ProducerStream.cs
@@ -42,7 +42,11 @@
             }
         }
 
-        public async Task<CommandSendReceipt> Send(ReadOnlySequence<byte> payload) => await Send(_cachedMetadata, payload);
+        public Task<CommandSendReceipt> Send(ReadOnlySequence<byte> payload)
+        {
+            _cachedMetadata.SequenceId = _sequenceId.Current;
+            return Send(_cachedMetadata, payload);
+        }
 
         public async Task<CommandSendReceipt> Send(PulsarApi.MessageMetadata metadata, ReadOnlySequence<byte> payload)
         {