From 1bc7932875c8cde4e49013ffe897b5193141b0af Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Thu, 25 Dec 2025 14:41:19 +0800 Subject: [PATCH] enhance: Explicitly set StartMessageIDInclusive to true for pulsar consumer (#46591) In pulsar-client-go v0.12, `Consumer.Seek()` **includes** the message at the seek position by default. However, in v0.17+, the default behavior changed to **exclude** the seek position message. This commit explicitly sets `StartMessageIDInclusive=true` when creating pulsar consumers to ensure consistent seek behavior and prevent potential message loss after upgrading the Pulsar client library. issue: https://github.com/milvus-io/milvus/issues/46589 pr: https://github.com/milvus-io/milvus/pull/46501 Signed-off-by: bigsheeper --- pkg/mq/msgstream/mqwrapper/pulsar/pulsar_client.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/mq/msgstream/mqwrapper/pulsar/pulsar_client.go b/pkg/mq/msgstream/mqwrapper/pulsar/pulsar_client.go index ca48ec39c0..35ad46edb2 100644 --- a/pkg/mq/msgstream/mqwrapper/pulsar/pulsar_client.go +++ b/pkg/mq/msgstream/mqwrapper/pulsar/pulsar_client.go @@ -119,6 +119,7 @@ func (pc *pulsarClient) Subscribe(ctx context.Context, options mqwrapper.Consume Type: pulsar.Exclusive, SubscriptionInitialPosition: pulsar.SubscriptionInitialPosition(options.SubscriptionInitialPosition), MessageChannel: receiveChannel, + StartMessageIDInclusive: true, }) if err != nil { metrics.MsgStreamOpCounter.WithLabelValues(metrics.CreateConsumerLabel, metrics.FailLabel).Inc()