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