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 module.
Can you get a new minor version released to PyPI of the master branch?