Hi All, I am new to Flink. While developing a Flink application We observed that our message is taking around 10 seconds between the two Async operators. Below are the details.
* Flink Flow: Kinesis Source -> Process -> Async1 -> Async2 -> Process -> Kinesis Sink * Environment: Amazon KDA. 1 Kinesis Processing Unit (1vCore & 4GB ram), and 1 parallelism. * Flink Version: 1.8.0 * Backpressure: Flink dashboard shows that backpressure is OK. * Input rate: 60 messages per second. Any kind of pointers/help will be very useful. Thanks, Sanket Agrawal