Hi Jesse, KafkaIO supports write: https://github.com/apache/incubator-beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L161
(This was merged over the weekend as part of @rangadi's https://github.com/apache/incubator-beam/pull/271) Dan On Tue, Jun 7, 2016 at 9:04 AM, Jesse Anderson <[email protected]> wrote: > Are there plans to add a writer to KafkaIO? Right now, it's only read. > > The class itself is written to only expect a reader. Adding any sort of > write would require refactoring the class to Read and Write like TextIO > does. > > Thanks, > > Jesse >
