Re: KafkaIO: Configurable timeout for setupInitialOffset()

2020-03-02 Thread Jozef Vilcek
Thanks Ismael! On Mon, Mar 2, 2020 at 2:15 PM Ismaël Mejía wrote: > Done, also assigned the issue you mentioned in the previous email to you. > > On Mon, Mar 2, 2020 at 12:56 PM Jozef Vilcek > wrote: > >> Recently I had a problem with Beam pipeline unable to start due to >> unhealthy broker in

Re: KafkaIO: Configurable timeout for setupInitialOffset()

2020-03-02 Thread Ismaël Mejía
Done, also assigned the issue you mentioned in the previous email to you. On Mon, Mar 2, 2020 at 12:56 PM Jozef Vilcek wrote: > Recently I had a problem with Beam pipeline unable to start due to > unhealthy broker in the list of configured bootstrap servers. I have > created a JIRA for it and pl

KafkaIO: Configurable timeout for setupInitialOffset()

2020-03-02 Thread Jozef Vilcek
Recently I had a problem with Beam pipeline unable to start due to unhealthy broker in the list of configured bootstrap servers. I have created a JIRA for it and plan to work on the fix. https://issues.apache.org/jira/browse/BEAM-9420 Please let me know in case it does not make sense of should be