We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4e979bb commit 5117256Copy full SHA for 5117256
ydb/core/kafka_proxy/actors/kafka_fetch_actor.cpp
@@ -35,7 +35,7 @@ void TKafkaFetchActor::SendFetchRequests(const TActorContext& ctx) {
35
TVector<NKikimr::NPQ::TPartitionFetchRequest> partPQRequests;
36
PrepareFetchRequestData(topicIndex, partPQRequests);
37
auto ruPerRequest = topicIndex == 0 && Context->Config.GetMeteringV2Enabled();
38
- NKikimr::NPQ::TFetchRequestSettings request(Context->DatabasePath, partPQRequests, FetchRequestData->MaxWaitMs, FetchRequestData->MaxBytes, Context->RlContext, *Context->UserToken, ruPerRequest);
+ NKikimr::NPQ::TFetchRequestSettings request(Context->DatabasePath, partPQRequests, FetchRequestData->MaxWaitMs, FetchRequestData->MaxBytes, Context->RlContext, *Context->UserToken, 0, ruPerRequest);
39
auto fetchActor = NKikimr::NPQ::CreatePQFetchRequestActor(request, NKikimr::MakeSchemeCacheID(), ctx.SelfID);
40
auto actorId = ctx.Register(fetchActor);
41
PendingResponses++;
0 commit comments