我为druid创建了数据模式，然后通过这个命令启用druid-kafka摄取

curl -XPOST -H'Content-Type: application/json' -d @quickstart/tutorial/my_schema.json http://localhost:8081/druid/indexer/v1/supervisor

到现在为止，一直都还不错。然后我用python制作了Kafka的剧本

for line in lines:

            producer.send('vtintel', value=line)
            sleep(1)

我可以通过kafka消费者获取数据，但不能在python的pydruid中获取数据。
当我想这样做的时候

from pydruid.db import connect

conn = connect(host='localhost', port=8082, path='/druid/v2/sql/', 
scheme='http')
curs = conn.cursor()
curs.execute("""
  SELECT detected,domain
  FROM vtintel
  LIMIT 10
""")
for row in curs:
   print(row)

我得到一个错误：

pydruid.db.exceptions.ProgrammingError: Unknown error (Unknown):