[GitHub] flink issue #5505: [FLINK-8538][table]Add a Kafka table source factory with ...

2018-02-17 Thread xccui 
Github user xccui commented on the issue:

https://github.com/apache/flink/pull/5505
  
Yes @twalthr, that will be great! I'll start working on the 
`KafkaAvroTableSourceFactory` and keep an eye on the API refactorings.


---

[GitHub] flink issue #5505: [FLINK-8538][table]Add a Kafka table source factory with ...

2018-02-17 Thread twalthr 
Github user twalthr commented on the issue:

https://github.com/apache/flink/pull/5505
  
Thanks for the PR @xccui. You are right, we should provide more utility 
method in `DescriptorProperties`. Especially for improving the interoperability 
Scala<->Java. I will fix those weaknesses next week and see if I can simply the 
logic in your PR.


---