File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
ydb/core/persqueue/public/fetcher Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -123,6 +123,7 @@ class TPQFetchRequestActor : public TActorBootstrapped<TPQFetchRequestActor>
123123 fetchInfo->Record .SetOffset (p.Offset );
124124 fetchInfo->Record .SetDeadline (deadline);
125125 fetchInfo->Record .SetCookie (i);
126+ fetchInfo->Record .SetClientId (Settings.Consumer );
126127 TopicInfo[topicPath].HasDataRequests [p.Partition ] = fetchInfo;
127128
128129 PartitionStatus[i] = EPartitionStatus::Unprocessed;
@@ -531,6 +532,7 @@ class TPQFetchRequestActor : public TActorBootstrapped<TPQFetchRequestActor>
531532 fetchInfo->Record .SetPartition (p.Partition );
532533 fetchInfo->Record .SetOffset (p.Offset );
533534 fetchInfo->Record .SetCookie (i);
535+ fetchInfo->Record .SetClientId (Settings.Consumer );
534536 fetchInfo->Record .SetDeadline (0 );
535537
536538 auto tabletId = topicInfo.PartitionToTablet [p.Partition ];
You can’t perform that action at this time.
0 commit comments