Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/6201
I agree with @fhueske. Let's do the `from-source` in a follow-up issue. I
will open a PR soon for FLINK-8558 which separates connector and format. For
this I also introduced a method `KafkaTableSource#supportsKafkaTimestamps`. The
`KafkaTableFactory` can read this property and throw an exception accordingly.---
