You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@beam.apache.org by John Casey <jo...@google.com> on 2022/04/29 17:08:14 UTC

Re-implementing Kafka withDynamicRead

Hi All,

I identified a bug with the Kafka withDynamicRead option, and I've written
up a quick document on how I plan to re-implement the option to make it work

https://docs.google.com/document/d/1Io49s5LBs29HJyppKG3AlR-gHz5m5PC6CqO0CCoSqLs/edit?usp=sharing

Any comments would be appreciated,

John