fix

nshestakov · nshestakov · commit 2443d0ceb67e · 2024-09-04T13:49:59.000Z
diff --git a/ydb/core/persqueue/partition.cpp b/ydb/core/persqueue/partition.cpp
@@ -2443,7 +2443,8 @@ void TPartition::EndChangePartitionConfig(NKikimrPQ::TPQTabletConfig&& config,
             keyRange = TPartitionKeyRange::Parse(mg.GetKeyRange());
         }
 
-        SourceIdStorage.RegisterSourceIdInfo(mg.GetId(), TSourceIdInfo(0, 0, ctx.Now(), std::move(keyRange)), true);
+        TSourceIdInfo sourceId(0, 0, ctx.Now(), std::move(keyRange), false);
+        SourceIdStorage.RegisterSourceIdInfo(mg.GetId(), std::move(sourceId), true);
     }
 
     TopicConverter = topicConverter;
diff --git a/ydb/core/persqueue/pq_impl.cpp b/ydb/core/persqueue/pq_impl.cpp
@@ -1807,7 +1807,7 @@ void TPersQueue::AddCmdWriteConfig(TEvKeyValue::TEvRequest* request,
             keyRange = TPartitionKeyRange::Parse(mg.GetKeyRange());
         }
 
-        sourceIdWriter.RegisterSourceId(mg.GetId(), 0, 0, ctx.Now(), std::move(keyRange));
+        sourceIdWriter.RegisterSourceId(mg.GetId(), 0, 0, ctx.Now(), std::move(keyRange), false);
     }
 
     for (const auto& partition : cfg.GetPartitions()) {

Original file line number	Diff line number	Diff line change
`@@ -2443,7 +2443,8 @@ void TPartition::EndChangePartitionConfig(NKikimrPQ::TPQTabletConfig&& config,`
`2443`	`2443`	`keyRange = TPartitionKeyRange::Parse(mg.GetKeyRange());`
`2444`	`2444`	`}`
`2445`	`2445`
`2446`		`- SourceIdStorage.RegisterSourceIdInfo(mg.GetId(), TSourceIdInfo(0, 0, ctx.Now(), std::move(keyRange)), true);`
	`2446`	`+ TSourceIdInfo sourceId(0, 0, ctx.Now(), std::move(keyRange), false);`
	`2447`	`+ SourceIdStorage.RegisterSourceIdInfo(mg.GetId(), std::move(sourceId), true);`
`2447`	`2448`	`}`
`2448`	`2449`
`2449`	`2450`	`TopicConverter = topicConverter;`
Original file line number	Diff line number	Diff line change
`@@ -1807,7 +1807,7 @@ void TPersQueue::AddCmdWriteConfig(TEvKeyValue::TEvRequest* request,`
`1807`	`1807`	`keyRange = TPartitionKeyRange::Parse(mg.GetKeyRange());`
`1808`	`1808`	`}`
`1809`	`1809`
`1810`		`- sourceIdWriter.RegisterSourceId(mg.GetId(), 0, 0, ctx.Now(), std::move(keyRange));`
	`1810`	`+ sourceIdWriter.RegisterSourceId(mg.GetId(), 0, 0, ctx.Now(), std::move(keyRange), false);`
`1811`	`1811`	`}`
`1812`	`1812`
`1813`	`1813`	`for (const auto& partition : cfg.GetPartitions()) {`