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 addressed somehow else. Thanks, Jozef
