default callback should raise (#794)

tim-quix · web-flow · commit f299616c885c · 2025-03-19T18:05:38.000+01:00
diff --git a/quixstreams/sinks/base/sink.py b/quixstreams/sinks/base/sink.py
@@ -18,6 +18,7 @@ def _default_on_client_connect_success():
 
 def _default_on_client_connect_failure(exception: Exception):
     logger.error(f"ERROR: Failed while connecting to client: {exception}")
+    raise exception
 
 
 class BaseSink(abc.ABC):
