Here in this Gist there is a simple Tornado app that produces to Kafka messages read from input. Run with python somple_tornado_app.py produce. There is also a full error output of the failure.
Did some research and it looks like it‘s because behavior of generators changed in Python 3.7. Now, you should not raise StopIteration manually in the generator, but instead of that just return.
With Python 3.7,
Producer.produce
fails within iterables.py:17, the drain function:
https://github.com/wglass/kiel/blob/12664fae522d95536c977bc3868951e7dce3daa0/kiel/iterables.py#L17
On Python 3.6 this works fine.
Here in this Gist there is a simple Tornado app that produces to Kafka messages read from
input
. Run withpython somple_tornado_app.py produce
. There is also a full error output of the failure.