Details

    • Sub-task
    • Status: Open
    • P2
    • Resolution: Unresolved
    • None
    • None
    • io-ideas, io-java-kafka
    • Production
    • Important

    Description

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

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              rdahal Ranjan Dahal
              Votes:
              1 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:

                Time Tracking

                  Estimated:
                  Original Estimate - 4h
                  4h
                  Remaining:
                  Time Spent - 1h Remaining Estimate - 3h
                  3h
                  Logged:
                  Time Spent - 1h Remaining Estimate - 3h
                  1h