Эх сурвалжийг харах

HUE-9077 [ksql] Adding commandStatus message to the result

Romain 6 жил өмнө
parent
commit
fbea472423

+ 3 - 0
desktop/libs/kafka/src/kafka/ksql_client.py

@@ -124,6 +124,9 @@ class KSqlApi(object):
           data.append(['', ''])
         else:
           data.append([key, result['sourceDescription'][key]])
+    elif result['@type'] == 'currentStatus':
+      data.append([result['commandStatus']['status']])
+      data.append([result['commandStatus']['message']])
 
     columns = [[col, 'STRING'] for col in columns]