Hi Marvin,
the CSV format is not supported for Kafka so far. Only formats that have
the tag `DeserializationSchema` in the docs are supported.
Right now you have to implement you own DeserializationSchemaFactory or
use JSON or Avro.
You can follow [1] to get informed once the CSV format is supported. I'm
sure it will be merge for Flink 1.8.
Regards,
Timo
[1] https://issues.apache.org/jira/browse/FLINK-7050
Am 11.12.18 um 10:41 schrieb Marvin777:
Register kafka message source with csv format, the error message is
as follows:
Exception in thread "main"
org.apache.flink.table.api.NoMatchingTableFactoryException: Could
not find a suitable table factory for
'org.apache.flink.table.factories.DeserializationSchemaFactory' in
the classpath.
Reason: No context matches.
BTW, the flink version is 1.6.2 .
Thanks Marvin.
image.png
