Merge pull request #22521 from vbotbuildovich/backport-pr-22327-v24.2…

….x-755

[v24.2.x] CORE-5749 retry on dns failure

src/v/kafka/client/broker.cc

@@ -17,6 +17,27 @@
 #include "rpc/rpc_utils.h"
 
 #include <seastar/core/coroutine.hh>
+#include <seastar/net/dns.hh>
+
+#include <ares.h>
+
+namespace {
+bool is_dns_failure_error(const std::system_error& e) {
+    if (e.code().category() == ss::net::dns::error_category()) {
+        switch (e.code().value()) {
+        case ARES_ENOTFOUND:
+        case ARES_ENODATA:
+        case ARES_ETIMEOUT:
+        case ARES_ECONNREFUSED:
+            return true;
+        default:
+            return false;
+        }
+    }
+
+    return false;
+}
+} // namespace
 
 namespace kafka::client {
 
@@ -50,7 +71,7 @@ ss::future<shared_broker_t> make_broker(
             });
       })
       .handle_exception_type([node_id](const std::system_error& ex) {
-          if (net::is_reconnect_error(ex)) {
+          if (net::is_reconnect_error(ex) || is_dns_failure_error(ex)) {
               return ss::make_exception_future<shared_broker_t>(
                 broker_error(node_id, error_code::network_exception));
           }

src/v/net/connection.cc

@@ -17,6 +17,8 @@
 #include <seastar/core/future.hh>
 #include <seastar/net/tls.hh>
 
+#include <system_error>
+
 namespace net {
 
 /**
@@ -40,7 +42,9 @@ bool is_reconnect_error(const std::system_error& e) {
     if (e.code().category() == ss::tls::error_category()) {
         return absl::c_any_of(
           ss_tls_reconnect_errors, [v](int ec) { return v == ec; });
-    } else {
+    } else if (
+      e.code().category() == std::system_category()
+      || e.code().category() == std::generic_category()) {
         switch (v) {
         case ECONNREFUSED:
         case ENETUNREACH:
@@ -58,6 +62,9 @@ bool is_reconnect_error(const std::system_error& e) {
         default:
             return false;
         }
+    } else {
+        // We don't know what the error category is at this point
+        return false;
     }
     __builtin_unreachable();
 }