fix

niksaveliev · niksaveliev · commit b03fd8bbccd4 · 2024-12-25T07:22:05.000Z
diff --git a/ydb/core/kafka_proxy/actors/kafka_balancer_actor.cpp b/ydb/core/kafka_proxy/actors/kafka_balancer_actor.cpp
@@ -518,7 +518,7 @@ void TKafkaBalancerActor::HandleSyncGroupResponse(
 
             IsMaster = (masterId == MemberId);
             if (!IsMaster) {
-                CurrentStep = SYNC_TX0_4_COMMIT_TX;
+                CurrentStep = SYNC_TX0_4_COMMIT_TX; // savnik abort TX
                 HandleSyncGroupResponse(ev, ctx);
                 return;
             }

Original file line number	Diff line number	Diff line change
`@@ -518,7 +518,7 @@ void TKafkaBalancerActor::HandleSyncGroupResponse(`
`518`	`518`
`519`	`519`	`IsMaster = (masterId == MemberId);`
`520`	`520`	`if (!IsMaster) {`
`521`		`- CurrentStep = SYNC_TX0_4_COMMIT_TX;`
	`521`	`+ CurrentStep = SYNC_TX0_4_COMMIT_TX; // savnik abort TX`
`522`	`522`	`HandleSyncGroupResponse(ev, ctx);`
`523`	`523`	`return;`
`524`	`524`	`}`