Current KafkaIO works just fine with Kafka 0.10. I don't know of any incompatibilities or regressions.
It does not take advantage of message timestamps, of course. It would be good to take handle tme in in a backward compatible way.. it might be required anyway if they are optional in 0.10. Not sure of scope of (1) below. I don't think it needs to be a new implementation. On Mon, Feb 6, 2017 at 11:35 AM, Xu Mingmin <[email protected]> wrote: > Hello, > > Is there anybody working on https://issues.apache.org/jira/browse/BEAM-307 > ? > The existing KafkaIO is implemented with Kafka 0.9, and not compatible well > with Kafka 0.10. > > I'd like to take this task if not duplicated: > 1). a new KafkaIO based on Kafka 0.10, suggest a separated project for > easy-to-build; > 2). use timestamp of Kafka message as default event-timestamp > > Thanks! > Mingmin >
