Our experience on this has been that if Kafka cluster is healthy, JVM resource
contentions on our Flink app caused by high heap utilization and there by lost
CPU cycles on GC also did result in this issue. Getting basic JVM metrics like
CPU load, GC times and Heap Util from your app (we use
Have you tried increasing the request.timeout.ms parameter (Kafka) ?
Which Flink / Kafka release are you using ?
Cheers
On Thu, Jul 5, 2018 at 5:39 AM Amol S - iProgrammer
wrote:
> Hello,
>
> I am using flink with kafka and getting below exception.
>
>
