diff --git a/ydb/services/persqueue_v1/actors/partition_writer_cache_actor.cpp b/ydb/services/persqueue_v1/actors/partition_writer_cache_actor.cpp index d1a182401410..f76a36d35950 100644 --- a/ydb/services/persqueue_v1/actors/partition_writer_cache_actor.cpp +++ b/ydb/services/persqueue_v1/actors/partition_writer_cache_actor.cpp @@ -199,6 +199,8 @@ void TPartitionWriterCacheActor::Handle(TEvents::TEvPoisonPill::TPtr& ev, const for (auto& [_, writer] : Writers) { ctx.Send(writer->Actor, new TEvents::TEvPoisonPill()); } + + Die(ctx); } auto TPartitionWriterCacheActor::GetPartitionWriter(const TString& sessionId, const TString& txId,