You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/03/01 03:20:09 UTC

[GitHub] [beam] nbali edited a comment on pull request #16909: Introducing KafkaIO.Read implementation compatibility testing

nbali edited a comment on pull request #16909:
URL: https://github.com/apache/beam/pull/16909#issuecomment-1054957601


   The project is in that progress for `KafkaIO` for over 1.5 year already, and it doesn't look like it will be completely replaced soon. Meanwhile the current state can be such a pita to use and the pipeline could do something different than you want it to do quietly so easily _right now_. I mean personally I don't wish the debug sessions I went through to anyone. I don't mind adding a `TODO` in the code to remove this once the SDF support has been fully implemented and it can finally completely replace the legacy solution, but I don't see how waiting for a future implementation/state that has no ETA would be better than shipping this in the upcoming release.


-- 
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: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org