浏览代码

[ksql] Handle without exception when ksql API returns empty

e.g. current behavior on INSERTs
Romain 5 年之前
父节点
当前提交
e82d4d79fe
共有 1 个文件被更改,包括 2 次插入2 次删除
  1. 2 2
      desktop/libs/kafka/src/kafka/ksql_client.py

+ 2 - 2
desktop/libs/kafka/src/kafka/ksql_client.py

@@ -103,8 +103,8 @@ class KSqlApi(object):
 
   def ksql(self, statement):
     response = self.client.ksql(statement)
-    print(response)
-    return response[0]
+    LOG.debug('ksqlDB response: %s' % response)
+    return response[0] if response else {'@type': 'queries', 'queries': []}  # INSERTs return empty currently
 
 
   def query(self, statement, channel_name=None):