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: image.png]