From d4d7a4b2853954ce2010642f54268452a7fea8c7 Mon Sep 17 00:00:00 2001 From: Ben Pope Date: Wed, 8 Nov 2023 09:10:03 +0000 Subject: [PATCH] net: GNUTLS_E_DECRYPTION_FAILED is_reconnect_error Signed-off-by: Ben Pope --- src/v/net/connection.cc | 1 + tests/rptest/tests/rpk_registry_test.py | 2 -- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/src/v/net/connection.cc b/src/v/net/connection.cc index 789b7b012b815..80fb5a02effd2 100644 --- a/src/v/net/connection.cc +++ b/src/v/net/connection.cc @@ -38,6 +38,7 @@ bool is_reconnect_error(const std::system_error& e) { case GNUTLS_E_UNSUPPORTED_VERSION_PACKET: case GNUTLS_E_NO_CIPHER_SUITES: case GNUTLS_E_PREMATURE_TERMINATION: + case GNUTLS_E_DECRYPTION_FAILED: return true; default: return false; diff --git a/tests/rptest/tests/rpk_registry_test.py b/tests/rptest/tests/rpk_registry_test.py index 2eb55148dd31e..090d6859fc1e6 100644 --- a/tests/rptest/tests/rpk_registry_test.py +++ b/tests/rptest/tests/rpk_registry_test.py @@ -284,7 +284,6 @@ def test_registry_subject(self): assert len(out) == 0 assert len(out_deleted) == 0 - @ok_to_fail @cluster(num_nodes=3) def test_produce_consume_avro(self): # First we register the schemas with their references. @@ -349,7 +348,6 @@ def test_produce_consume_avro(self): assert json.loads(msg["value"]) == expected_msg_1 assert json.loads(msg["key"]) == expected_msg_2 - @ok_to_fail @cluster(num_nodes=3) def test_produce_consume_proto(self): # First we register the schemas with their references.