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 2021/06/14 07:39:26 UTC

[GitHub] [beam] youngoli commented on pull request #14996: [BEAM-12380] Add KafkaIO Transforms and Kafka Taxi example.

youngoli commented on pull request #14996:
URL: https://github.com/apache/beam/pull/14996#issuecomment-859280192


   R: @lostluck 
   
   As the title indicates, this change is not _quite_ done, but it's close enough that I think it's ready for review and I don't want to delay it any longer since it's already spent a bit too long brewing.
   
   I documented all the changes you can expect up above, but to reiterate: You can skip all the Kafka examples I wrote except the top-level one (examples/kafka/taxi.go) that I'll be keeping. All other files will probably only have minor changes and should be ready enough for review.


-- 
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.

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