search

bryanyang0528 / ksql-python

A python wrapper for the KSQL REST API.
MIT License
159 stars 67 forks source link

query timeout if i dont put limit in query. #63

Closed varunajmera0 closed 4 years ago

varunajmera0 commented 4 years ago

How can we get continues data from stream client = KSQLAPI('http://127.0.0.1:8088') streamProperties = {"ksql.streams.auto.offset.reset": "earliest"} def cal(): def events(): query_string="select * from trend_news_stream emit changes;" q = client.query(query_string, stream_properties=streamProperties, idle_timeout=10) for c in q: yield c return Response(events(), mimetype="text/event-stream")

romainr commented 4 years ago

Check https://github.com/bryanyang0528/ksql-python/pull/60

bryanyang0528 commented 4 years ago

fixed in #60 and #67 please open a new issue if you are in any trouble. thx!