Skip to content

Commit dda41e5

Browse files
Revert "Initializing the configuration of the partition (#15557) (#15577)" (#15828)
1 parent 5c53ee8 commit dda41e5

File tree

3 files changed

+1
-7
lines changed

3 files changed

+1
-7
lines changed

ydb/core/persqueue/partition.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2757,7 +2757,7 @@ void TPartition::EndChangePartitionConfig(NKikimrPQ::TPQTabletConfig&& config,
27572757

27582758
TString TPartition::GetKeyConfig() const
27592759
{
2760-
return Sprintf("_config_%u", Partition.InternalPartitionId);
2760+
return Sprintf("_config_%u", Partition.OriginalPartitionId);
27612761
}
27622762

27632763
void TPartition::ChangePlanStepAndTxId(ui64 step, ui64 txId)

ydb/core/persqueue/partition_init.cpp

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -200,11 +200,6 @@ void TInitConfigStep::Handle(TEvKeyValue::TEvResponse::TPtr& ev, const TActorCon
200200
Y_ABORT("bad status");
201201
};
202202

203-
// There should be no consumers in the configuration of the background partition. When creating a partition,
204-
// the PQ tablet specifically removes all consumer settings from the config.
205-
Y_ABORT_UNLESS(!Partition()->IsSupportive() ||
206-
(Partition()->Config.GetConsumers().empty() && Partition()->TabletConfig.GetConsumers().empty()));
207-
208203
Partition()->PartitionConfig = GetPartitionConfig(Partition()->Config, Partition()->Partition.OriginalPartitionId);
209204
Partition()->PartitionGraph = MakePartitionGraph(Partition()->Config);
210205

ydb/core/persqueue/pq_impl.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -865,7 +865,6 @@ NKikimrPQ::TPQTabletConfig TPersQueue::MakeSupportivePartitionConfig() const
865865
partitionConfig.MutableReadRuleServiceTypes()->Clear();
866866
partitionConfig.MutableReadRuleVersions()->Clear();
867867
partitionConfig.MutableReadRuleGenerations()->Clear();
868-
partitionConfig.MutableConsumers()->Clear();
869868

870869
return partitionConfig;
871870
}

0 commit comments

Comments
 (0)