ksql-python
ksql-python copied to clipboard
bryanyang0528
A python wrapper for the KSQL REST API.
Change http connection dependency Add httpx in requirements.txt Change api.py
Because the Travis CI is no more free for open source, we have to migrate the project to the Circle CI
i'm receiving the following error after inserting into a stream using ```python client.ksql("INSERT INTO riderLocations (profileId, latitude, longitude) VALUES ('4ab5cbad', 37.3952, -122.0813);")` ``` Traceback (most recent call last): File "",...
It would be nice to get the code coverage to 100%. Then the report would immediately jump out at you whenever a line of code is missed during any newly...
when i use 'use_http2=True' parameter in the query function, the data is retrieved and when the kafka stream stops sending data for more than 5 secs the python code throws...
When I make a ksql query using the `ksql-cli` and `curl`, It works fine. Making the same query using this library doesn't work. After investigating the issue, it looks like...
There's a bugfix on the master branch that's not currently available when you download this from pypi: namely a `try...except StopIteration` block was added in the `process_query_results` function in `ksql.utils`...
I'm trying to read from ksql in python with this script: ``` from ksql import KSQLAPI client = KSQLAPI('http://0.0.0.0:8088',) columns = ['id INT','name VARCHAR'] client.create_stream(table_name='students', columns_type= columns, topic='students') query =...
``` Traceback (most recent call last): File "/app/consumer.py", line 17, in import ksql File "/usr/local/lib/python3.10/site-packages/ksql/__init__.py", line 6, in from ksql.client import KSQLAPI # noqa File "/usr/local/lib/python3.10/site-packages/ksql/client.py", line 4, in from...
This is my first issue, so sorry if i missed something. I have encountered an issue when reading data from a stream using a PULL Query (im new to KSQL...
