[ksql] Adding commandStatus message to the result
@@ -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]
