From ae534bbc420e804c96c4eb9c07b93a26d430dd0f Mon Sep 17 00:00:00 2001
From: Nikolay Shestakov <tesseract@ydb.tech>
Date: Wed, 8 Oct 2025 14:02:21 +0000
Subject: [PATCH] Added consumer to HasData request

---
 ydb/core/persqueue/public/fetcher/fetch_request_actor.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/ydb/core/persqueue/public/fetcher/fetch_request_actor.cpp b/ydb/core/persqueue/public/fetcher/fetch_request_actor.cpp
index 339cb8f03f7f..ca848cd62717 100644
--- a/ydb/core/persqueue/public/fetcher/fetch_request_actor.cpp
+++ b/ydb/core/persqueue/public/fetcher/fetch_request_actor.cpp
@@ -123,6 +123,7 @@ class TPQFetchRequestActor : public TActorBootstrapped<TPQFetchRequestActor>
             fetchInfo->Record.SetOffset(p.Offset);
             fetchInfo->Record.SetDeadline(deadline);
             fetchInfo->Record.SetCookie(i);
+            fetchInfo->Record.SetClientId(Settings.Consumer);
             TopicInfo[topicPath].HasDataRequests[p.Partition] = fetchInfo;
 
             PartitionStatus[i] = EPartitionStatus::Unprocessed;
@@ -536,6 +537,7 @@ class TPQFetchRequestActor : public TActorBootstrapped<TPQFetchRequestActor>
                 fetchInfo->Record.SetPartition(p.Partition);
                 fetchInfo->Record.SetOffset(p.Offset);
                 fetchInfo->Record.SetCookie(i);
+                fetchInfo->Record.SetClientId(Settings.Consumer);
                 fetchInfo->Record.SetDeadline(0);
 
                 auto tabletId = topicInfo.PartitionToTablet[p.Partition];