Re: Any python example with json data from Kafka using flink-statefun

2020-06-15 Thread Sunil Sattiraju
ithub.com/apache/flink-statefun/blob/8376afa6b064bfa2374eefbda5e149cd490985c0/statefun-examples/statefun-python-greeter-example/greeter/messages.proto#L25 > > On Mon, Jun 15, 2020 at 4:25 PM Sunil Sattiraju > wrote: > > > Hi, Based on the example from > > https://gi

Any python example with json data from Kafka using flink-statefun

2020-06-15 Thread Sunil Sattiraju
Hi, Based on the example from https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-python-greeter-example I am trying to ingest json data in kafka, but unable to achieve based on the examples. event-generator.py def produce(): request = {} request['id'] = "ab