Go ahead ! My suggestion was to create one IO module per version (kafka-0.9, kafka-0.10 for instance).
I think it's easier to maintain. Regards JB On Feb 6, 2017, 15:35, at 15:35, 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
