Fix the startMessageId can't be respected as the ChunkMessageID

src/Pulsar.Client/Internal/ConsumerImpl.fs

@@ -85,7 +85,14 @@ type internal ConsumerImpl<'T> (consumerConfig: ConsumerConfiguration<'T>, clien
     let subscribeTimeout = DateTime.Now.Add(clientConfig.OperationTimeout)
     let mutable hasReachedEndOfTopic = false
     let mutable avalablePermits = 0
-    let mutable startMessageId = startMessageId
+    let mutable startMessageId =
+        match startMessageId with
+        | Some startMsgId ->
+            match startMsgId.ChunkMessageIds with
+            | Some chunkMessageIds when chunkMessageIds.Length > 0 ->
+                Some(chunkMessageIds[0])
+            | _ -> Some(startMsgId)
+        | None -> None
     let mutable lastMessageIdInBroker = MessageId.Earliest
     let mutable lastDequeuedMessageId = MessageId.Earliest
     let mutable duringSeek = None

tests/IntegrationTests/Chunks.fs

@@ -185,6 +185,17 @@ let tests =
                 Expect.equal "" msgIds.[i] msgAfterSeek.MessageId
 
             do! consumer.UnsubscribeAsync()
+
+            let! (reader :  IReader<byte[]>) =
+                client.NewReader()
+                    .Topic(topicName)
+                    .StartMessageIdInclusive()
+                    .StartMessageId(msgIds.[1])
+                    .CreateAsync()
+
+            let! (readMsg : Message<byte[]>) = reader.ReadNextAsync()
+            Expect.equal "" msgIds.[1] readMsg.MessageId      
+
             Log.Debug("Ended Seek chunk messages and receive correctly")
         }
     ]