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 <am...@iprogrammer.com> wrote: > Hello, > > I am using flink with kafka and getting below exception. > > org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for > helloworld.t-7: 30525 ms has passed since last append > > ----------------------------------------------- > *Amol Suryawanshi* > Java Developer > am...@iprogrammer.com > > > *iProgrammer Solutions Pvt. Ltd.* > > > > *Office 103, 104, 1st Floor Pride Portal,Shivaji Housing Society, > Bahiratwadi,Near Hotel JW Marriott, Off Senapati Bapat Road, Pune - 411016, > MH, INDIA.**Phone: +91 9689077510 | Skype: amols_iprogrammer* > www.iprogrammer.com <sac...@iprogrammer.com> > ------------------------------------------------ >
