|
@@ -104,7 +104,7 @@ class KSqlApi(object):
|
|
|
|
|
|
|
|
if result['@type'] == 'statement_error':
|
|
if result['@type'] == 'statement_error':
|
|
|
raise KSqlApiException(result['message'])
|
|
raise KSqlApiException(result['message'])
|
|
|
- elif result['@type'] in ('kafka_topics', 'streams'):
|
|
|
|
|
|
|
+ elif result['@type'] in ('kafka_topics', 'streams', 'tables'):
|
|
|
result_type = 'topics' if result['@type'] == 'kafka_topics' else result['@type']
|
|
result_type = 'topics' if result['@type'] == 'kafka_topics' else result['@type']
|
|
|
columns = result[result_type][0].keys()
|
|
columns = result[result_type][0].keys()
|
|
|
for line in result[result_type]:
|
|
for line in result[result_type]:
|