Ah the over the weekend part explains that. Is there a reason KafkaIO doesn't follow the separate classes for read and write like TextIO does? Following the TextIO style, there should be a KafkaIO.Read.method() or KafkaIO.Write.method().
On Tue, Jun 7, 2016 at 12:22 PM Dan Halperin <[email protected]> wrote: > 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 >> > >
