Optimize the writing session creation time (#19807)

Author: Alek5andr-Kotov

ydb/core/persqueue/writer/writer.cpp

@@ -254,6 +254,10 @@ class TPartitionWriter : public TActorBootstrapped<TPartitionWriter>, private TR
     /// GetWriteId
 
     void GetWriteId(const TActorContext& ctx) {
+        INFO("Start of a request to KQP for a WriteId. " <<
+             "SessionId: " << Opts.SessionId <<
+             " TxId: " << Opts.TxId);
+
         auto ev = MakeWriteIdRequest();
         ctx.Send(NKqp::MakeKqpProxyID(ctx.SelfID.NodeId()), ev.Release());
         Become(&TThis::StateGetWriteId);
@@ -270,6 +274,10 @@ class TPartitionWriter : public TActorBootstrapped<TPartitionWriter>, private TR
     }
 
     void HandleWriteId(NKqp::TEvKqp::TEvQueryResponse::TPtr& ev, const TActorContext& ctx) {
+        INFO("End of the request to KQP for the WriteId. " <<
+             "SessionId: " << Opts.SessionId <<
+             " TxId: " << Opts.TxId);
+
         auto& record = ev->Get()->Record;
         switch (record.GetYdbStatus()) {
         case Ydb::StatusIds::SUCCESS:
@@ -404,11 +412,19 @@ class TPartitionWriter : public TActorBootstrapped<TPartitionWriter>, private TR
         Y_ABORT_UNLESS(HasWriteId());
         Y_ABORT_UNLESS(HasSupportivePartitionId());
 
+        INFO("Start of a request to KQP to save PartitionId. " <<
+             "SessionId: " << Opts.SessionId <<
+             " TxId: " << Opts.TxId);
+
         auto ev = MakeWriteIdRequest();
         ctx.Send(NKqp::MakeKqpProxyID(ctx.SelfID.NodeId()), ev.Release());
     }
 
     void HandlePartitionIdSaved(NKqp::TEvKqp::TEvQueryResponse::TPtr& ev, const TActorContext&) {
+        INFO("End of a request to KQP to save PartitionId. " <<
+             "SessionId: " << Opts.SessionId <<
+             " TxId: " << Opts.TxId);
+
         auto& record = ev->Get()->Record;
         switch (record.GetYdbStatus()) {
         case Ydb::StatusIds::SUCCESS:
@@ -968,7 +984,10 @@ class TPartitionWriter : public TActorBootstrapped<TPartitionWriter>, private TR
     using IRetryState = IRetryPolicy::IRetryState;
 
     static IRetryPolicy::TPtr GetRetryPolicy() {
-        return IRetryPolicy::GetExponentialBackoffPolicy(Retryable);
+        return IRetryPolicy::GetExponentialBackoffPolicy(Retryable,
+                                                         TDuration::MilliSeconds(10),
+                                                         TDuration::MilliSeconds(10),
+                                                         TDuration::MilliSeconds(100));
     };
 
     static ERetryErrorClass Retryable(Ydb::StatusIds::StatusCode code) {