Merge pull request #8578 from michael-redpanda/issue-8072

kafka/client: Better system_error handling
redpanda-data · Feb 3, 2023 · 7a0ef9e · 7a0ef9e
2 parents 2f4d81b + 8785fa8
commit 7a0ef9e
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/v/kafka/client/broker.h b/src/v/kafka/client/broker.h
@@ -82,6 +82,13 @@ class broker : public ss::enable_lw_shared_from_this<broker> {
                 return ss::make_exception_future<Ret>(
                   broker_error(_node_id, error_code::broker_not_available));
             })
+          .handle_exception_type([this](const std::system_error& e) {
+              if (net::is_reconnect_error(e)) {
+                  return ss::make_exception_future<Ret>(
+                    broker_error(_node_id, error_code::broker_not_available));
+              }
+              return ss::make_exception_future<Ret>(e);
+          })
           .finally([b = shared_from_this()]() {});
     }