[Kafka api] Fix kafka transaction bug when EnableOltpSink=false (#21297)

Co-authored-by: Irene Skvortsova <[email protected]>
Co-authored-by: Irina Skvortsova <[email protected]>

1 files changed, 1 insertions, 1 deletions

diff --git a/ydb/core/kqp/executer_actor/kqp_data_executer.cpp b/ydb/core/kqp/executer_actor/kqp_data_executer.cpp
index 45cafc0067e..df0583b2343 100644
--- a/ydb/core/kqp/executer_actor/kqp_data_executer.cpp
+++ b/ydb/core/kqp/executer_actor/kqp_data_executer.cpp
@@ -2834,7 +2834,7 @@ private:
                 auto* w = transaction.MutableWriteId();
                 w->SetNodeId(SelfId().NodeId());
                 w->SetKeyId(*writeId);
-            } else if (Request.TopicOperations.HasKafkaOperations() && Request.TopicOperations.HasWriteOperations()) {
+            } else if (Request.TopicOperations.HasKafkaOperations() && t.hasWrite) {
                 auto* w = transaction.MutableWriteId();
                 w->SetKafkaTransaction(true);
                 w->MutableKafkaProducerInstanceId()->SetId(Request.TopicOperations.GetKafkaProducerInstanceId().Id);