[ksql] Support SHOW QUERIES
@@ -104,8 +104,9 @@ class KSqlApi(object):
if result['@type'] == 'statement_error':
raise KSqlApiException(result['message'])
- elif result['@type'] in ('kafka_topics', 'streams', 'tables'):
+ elif result['@type'] in ('kafka_topics', 'streams', 'tables', 'queries'):
result_type = 'topics' if result['@type'] == 'kafka_topics' else result['@type']
+ if result[result_type]:
columns = result[result_type][0].keys()
for line in result[result_type]:
row = []
