sdk, can i do that using the
java/scala sdk?
Thanks.
On 2020/06/15 15:34:39, Sunil Sattiraju wrote:
> Thanks Igal,
> I dont have control over the data source inside kafka ( current kafka topic
> contains either json or avro formats only, i am trying to reproduce this
> scenari
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
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
