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 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