Hi Marvin, I had taken a look at the Flink code. It seems we can't use CSV format for Kafka. You can use JSON instead. As the exception shows, Flink can't find a suitable DeserializationSchemaFactory. Currently, only JSON and Avro support DeserializationSchemaFactory.
Best, Hequn On Tue, Dec 11, 2018 at 5:48 PM Marvin777 <xymaqingxiang...@gmail.com> wrote: > 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] > >
