BEAM-307(KafkaIO on Kafka 0.10)

[Xu Mingmin]

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