diff options
| author | savnik <savnik@yandex-team.com> | 2023-11-21 15:11:38 +0300 |
|---|---|---|
| committer | savnik <savnik@yandex-team.com> | 2023-11-21 17:31:03 +0300 |
| commit | 24bcbcd984df2f69e28a6c77c54ceaac9b8fa547 (patch) | |
| tree | 1c89e1c74ba10a2aeaccd60dff80bc98b0aba480 | |
| parent | 6090489987a544cb9d01b2e4d3ad657ad7322ce6 (diff) | |
| download | ydb-24bcbcd984df2f69e28a6c77c54ceaac9b8fa547.tar.gz | |
Fix kafka tests
fix tests
| -rw-r--r-- | ydb/core/kafka_proxy/ut/ut_protocol.cpp | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/ydb/core/kafka_proxy/ut/ut_protocol.cpp b/ydb/core/kafka_proxy/ut/ut_protocol.cpp index dd0662f2a7..752fcf15bc 100644 --- a/ydb/core/kafka_proxy/ut/ut_protocol.cpp +++ b/ydb/core/kafka_proxy/ut/ut_protocol.cpp @@ -591,7 +591,7 @@ Y_UNIT_TEST_SUITE(KafkaProtocol) { auto msg = client.ApiVersions(); UNIT_ASSERT_VALUES_EQUAL(msg->ErrorCode, static_cast<TKafkaInt16>(EKafkaErrors::NONE_ERROR)); - UNIT_ASSERT_VALUES_EQUAL(msg->ApiKeys.size(), 9u); + UNIT_ASSERT_VALUES_EQUAL(msg->ApiKeys.size(), 15u); } { @@ -815,7 +815,7 @@ Y_UNIT_TEST_SUITE(KafkaProtocol) { auto msg = client.ApiVersions(); UNIT_ASSERT_VALUES_EQUAL(msg->ErrorCode, static_cast<TKafkaInt16>(EKafkaErrors::NONE_ERROR)); - UNIT_ASSERT_VALUES_EQUAL(msg->ApiKeys.size(), 9u); + UNIT_ASSERT_VALUES_EQUAL(msg->ApiKeys.size(), 15u); } { @@ -1014,7 +1014,6 @@ Y_UNIT_TEST_SUITE(KafkaProtocol) { TString group = "consumer-0"; TString notExistsGroup = "consumer-not-exists"; - NYdb::NTopic::TTopicClient pqClient(*testServer.Driver); { auto result = @@ -1188,7 +1187,7 @@ Y_UNIT_TEST_SUITE(KafkaProtocol) { auto msg = client.ApiVersions(); UNIT_ASSERT_VALUES_EQUAL(msg->ErrorCode, static_cast<TKafkaInt16>(EKafkaErrors::NONE_ERROR)); - UNIT_ASSERT_VALUES_EQUAL(msg->ApiKeys.size(), 9u); + UNIT_ASSERT_VALUES_EQUAL(msg->ApiKeys.size(), 15u); } { |