Skip to content

Commit 6dc2e21

Browse files
Fix windows build (#16042)
1 parent 0a45be2 commit 6dc2e21

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

ydb/core/kafka_proxy/actors/kafka_init_producer_id_actor.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,7 @@ namespace NKafka {
152152
case UPDATE:
153153
OnSuccessfullProducerStateUpdate(ev, ctx);
154154
break;
155-
case DELETE:
155+
case DELETE_REQ:
156156
SendInsertRequest(ctx);
157157
break;
158158
default:
@@ -211,7 +211,7 @@ namespace NKafka {
211211
void TKafkaInitProducerIdActor::SendDeleteByTransactionalIdRequest(const TActorContext& ctx) {
212212
Kqp->SendYqlRequest(GetYqlWithTableName(NInitProducerIdSql::DELETE_BY_TRANSACTIONAL_ID), BuildSelectOrDeleteByTransactionalIdParams(), ++KqpReqCookie, ctx, false);
213213

214-
LastSentToKqpRequest = EInitProducerIdKqpRequests::DELETE;
214+
LastSentToKqpRequest = EInitProducerIdKqpRequests::DELETE_REQ;
215215
}
216216

217217
// params builders
@@ -329,7 +329,7 @@ namespace NKafka {
329329
return "INSERT";
330330
case UPDATE:
331331
return "UPDATE";
332-
case DELETE:
332+
case DELETE_REQ:
333333
return "DELETE";
334334
case NO_REQUEST:
335335
return "NO_REQUEST";

ydb/core/kafka_proxy/actors/kafka_init_producer_id_actor.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ namespace NKafka {
2424
SELECT,
2525
INSERT,
2626
UPDATE,
27-
DELETE,
27+
DELETE_REQ, // we can't call it DELETE, cause DELETE macros is already defined in contrib/restricted/cprocsp/include/cpcsp/CSP_WinDef.h
2828
BEGIN_TRANSACTION
2929
};
3030

0 commit comments

Comments
 (0)