Hi In my flink application I need to enrich data using AsyncDataStream.unorderedWait but I am getting poor perforce at the beginning I was just working with http call, but I have switched to grpc, I running on 8 core node and getting total of 3200 events per second my service that I am using is not fully utilized and can produce up to 10000 req/seq
Flink job flow Reading from Kafka ~> some enrichment with unoderedwait ~> map ~> write to Kafka Using Akkad grpc code written in scala Thanks
