Hi team, I'm working on KafkaIO dynamic read support which is tracked by BEAM-11325 <https://issues.apache.org/jira/browse/BEAM-11325> and I started the documentation here: https://docs.google.com/document/d/1FU3GxVRetHPLVizP3Mdv6mP5tpjZ3fd99qNjUI5DT5k/edit?usp=sharing, which states the problem I want to solve and the proposed solutions.
Please feel free to drop any comments/concerns/suggestions/ideas : ) If the design looks good in general, I'll start the dev work as soon as possible. Thanks for your help!
