diff --git a/confluent_client/bin/confetty b/confluent_client/bin/confetty
index 3844f6b8..e4e30e6d 100755
--- a/confluent_client/bin/confetty
+++ b/confluent_client/bin/confetty
@@ -299,8 +299,11 @@ currchildren = None
 
 
 def print_result(res):
+    global exitcode
     if 'errorcode' in res or 'error' in res:
         print(res['error'])
+        if 'errorcode' in res:
+            exitcode |= res['errorcode']
         return
     if 'databynode' in res:
         print_result(res['databynode'])