Ranjan Dahal created BEAM-13298:
-----------------------------------
Summary: JdbcIO like withResults() for KafkaIO
Key: BEAM-13298
URL: https://issues.apache.org/jira/browse/BEAM-13298
Project: Beam
Issue Type: Bug
Components: io-ideas
Affects Versions: 2.34.0
Environment: Production
Reporter: Ranjan Dahal
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)
