Skip to content

Commit fbc9d17

Browse files
authored
Fix iterator (#1612)
1 parent 9bf348b commit fbc9d17

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

ydb/core/kafka_proxy/kafka_connection.cpp

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -319,7 +319,14 @@ class TKafkaConnection: public TActorBootstrapped<TKafkaConnection>, public TNet
319319
KAFKA_LOG_D("process message: ApiKey=" << Request->Header.RequestApiKey << ", ExpectedSize=" << Request->ExpectedSize
320320
<< ", Size=" << Request->Size);
321321

322-
Request->Method = EApiKeyNames.find(static_cast<EApiKey>(Request->Header.RequestApiKey))->second;
322+
auto apiKeyNameIt = EApiKeyNames.find(static_cast<EApiKey>(Request->Header.RequestApiKey));
323+
if (apiKeyNameIt == EApiKeyNames.end()) {
324+
KAFKA_LOG_ERROR("Unsupported message: ApiKey=" << Request->Header.RequestApiKey);
325+
PassAway();
326+
return false;
327+
}
328+
329+
Request->Method = apiKeyNameIt->second;
323330

324331
PendingRequestsQueue.push_back(Request);
325332
PendingRequests[Request->Header.CorrelationId] = Request;

0 commit comments

Comments
 (0)