diff options
| author | komels <komels@ydb.tech> | 2023-08-07 08:43:59 +0300 |
|---|---|---|
| committer | komels <komels@ydb.tech> | 2023-08-07 09:14:21 +0300 |
| commit | 382ecfbdf714ad4e01c41c122c70ccd41e50730e (patch) | |
| tree | 459df00c3359fbf3950ed2218ae949bf147d5b67 | |
| parent | 8b1059bcd3ad8b0494b960be5101247dde4b5589 (diff) | |
| download | ydb-382ecfbdf714ad4e01c41c122c70ccd41e50730e.tar.gz | |
Fix the bug
| -rw-r--r-- | ydb/core/kafka_proxy/kafka_metadata_actor.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/kafka_proxy/kafka_metadata_actor.cpp b/ydb/core/kafka_proxy/kafka_metadata_actor.cpp index 9f6ee86e369..e74540860cc 100644 --- a/ydb/core/kafka_proxy/kafka_metadata_actor.cpp +++ b/ydb/core/kafka_proxy/kafka_metadata_actor.cpp @@ -111,9 +111,9 @@ void TKafkaMetadataActor::HandleResponse(TEvLocationResponse::TPtr ev, const TAc } void TKafkaMetadataActor::RespondIfRequired(const TActorContext& ctx) { - if (--PendingResponses == 0) { + if (PendingResponses == 0) { Send(Parent, new TEvKafka::TEvResponse(Cookie, Response)); Die(ctx); } } -} // namespace NKafka
\ No newline at end of file +} // namespace NKafka |