nbali commented on pull request #16773: URL: https://github.com/apache/beam/pull/16773#issuecomment-1054131752
> Semantically, it seems like this should result in bounded PCollections, even though the batch read of those PCollections may be inefficient and/or blocking. I think that is one thing we all agree on that for `KafkaIO` the code should actually be separated into unbounded/bounded for these scenarios and having completely different codepaths would be the proper way to solve that one. This is strictly about giving developers the ability to _circumvent_ cases where that implementations does not exist yet. I really can't see how having this option - disabled by default - could hurt. As far as I can tell if the experiment hasn't been enabled it behaves exactly the same. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
