[jira] [Work logged] (BEAM-13298) Add "withResults()" for KafkaIO.write

["ASF GitHub Bot (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-13298?focusedWorklogId=756357&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-756357 ]

ASF GitHub Bot logged work on BEAM-13298:
-----------------------------------------

                Author: ASF GitHub Bot
            Created on: 13/Apr/22 12:52
            Start Date: 13/Apr/22 12:52
    Worklog Time Spent: 10m 
      Work Description: github-actions[bot] commented on PR #16835:
URL: https://github.com/apache/beam/pull/16835#issuecomment-1098013577

   This pull request has been marked as stale due to 60 days of inactivity. It will be closed in 1 week if no further activity occurs. If you think that’s incorrect or this pull request requires a review, please simply write any comment. If closed, you can revive the PR at any time and @mention a reviewer or discuss it on the dev@beam.apache.org list. Thank you for your contributions.




Issue Time Tracking
-------------------

            Worklog Id:     (was: 756357)
    Remaining Estimate: 3h 40m  (was: 3h 50m)
            Time Spent: 20m  (was: 10m)

> Add "withResults()" for KafkaIO.write
> -------------------------------------
>
>                 Key: BEAM-13298
>                 URL: https://issues.apache.org/jira/browse/BEAM-13298
>             Project: Beam
>          Issue Type: Sub-task
>          Components: io-ideas, io-java-kafka
>         Environment: Production
>            Reporter: Ranjan Dahal
>            Priority: P2
>              Labels: KafkaIO
>   Original Estimate: 4h
>          Time Spent: 20m
>  Remaining Estimate: 3h 40m
>
> I am looking at use case where we have to wait until the Kafka Write operation is completed before we can move forward with another transform. Currently, JdbcIO support withResults() which waits for the previous transform to complete as part of Wait.on(Signal) and moves on to the next. 
> Similarly, it would be very beneficial to have this capability on KafkaIO (and others like PubSubIO, BigQueryIO etc). 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)