Re: Error: Timeout of 60000ms expired before the position for partition

2021-10-04 Thread Dawid Wysakowicz
Hi, Do you mean that you fail to start Kafka? Or do you get the exception from Flink. Could you please share the full stack trace of the error? Best, Dawid On 02/10/2021 16:58, Dipanjan Mazumder wrote: > Hi, > >   I am getting below error while starting the flink as a standalone > single jvm pr

Error: Timeout of 60000ms expired before the position for partition

2021-10-02 Thread Dipanjan Mazumder
Hi,   I am getting below error while starting the flink as a standalone single jvm process through jar. The kafka is deployed as a seperate cluster and the process is not able to start and fails with below error after 60sec: org.apache.kafka.common.errors.TimeoutException: Timeout of 6ms expi