Retain ordering key on ReconsumeLater

src/Pulsar.Client/Internal/DeadLetters.fs

@@ -89,7 +89,8 @@ type internal DeadLetterProcessor<'T>
                     let! rlProducer = rlProducer.Value
                     let key = getOptionalKey message
                     let eventTime = message.EventTime |> Option.ofNullable
-                    let msg = MessageBuilder(message.GetValue(), message.Data, key, propertiesMap, deliverAt, ?eventTime = eventTime)
+                    let orderingKey = message.OrderingKey |> Option.ofObj
+                    let msg = MessageBuilder(message.GetValue(), message.Data, key, propertiesMap, deliverAt, ?orderingKey = orderingKey, ?eventTime = eventTime)
                     let! _ = rlProducer.SendAsync(msg)
                     acknowledge message.MessageId
             }

tests/IntegrationTests/DeadLetters.fs

@@ -448,6 +448,44 @@ let tests =
 
             description |> logTestEnd
         }
+
+
+        testTask "Reconsume later retains ordering key" {
+
+            let description = "Reconsume later retains ordering key"
+
+            description |> logTestStart
+
+            let config = getTestConfig()
+            let producerName = "reconsumeProducer"
+            let consumerName = "reconsumeConsumer"
+
+            let! (producer : IProducer<byte[]>) =
+                createProducer()
+                    .ProducerName(producerName)
+                    .Topic(config.TopicName)
+                    .EnableBatching(false)
+                    .CreateAsync()
+
+            let! (consumer : IConsumer<byte[]>) =
+                createConsumer()
+                    .ConsumerName(consumerName)
+                    .Topic(config.TopicName)
+                    .SubscriptionName(config.SubscriptionName)
+                    .EnableRetry(true)
+                    .SubscribeAsync()
+
+            let orderingKey = [| 1uy; 0uy; 1uy |]
+            let! _ = producer.NewMessage([| 0uy; 1uy; 0uy |], orderingKey = orderingKey) |> producer.SendAsync
+            let! (msg1 : Message<byte[]>) = consumer.ReceiveAsync()
+            do! consumer.ReconsumeLaterAsync(msg1, %(DateTime.UtcNow.AddSeconds(1.0) |> convertToMsTimestamp))
+            let! (msg2 : Message<byte[]>) = consumer.ReceiveAsync()
+
+            Expect.equal "" orderingKey msg1.OrderingKey
+            Expect.equal "" orderingKey msg2.OrderingKey
+
+            description |> logTestEnd
+        }
 
         testTask "Dead-letter initial subscription is created" {