exactly! I initially thought this class is in table API. I was building a custom table source and found I have to add Kafka connector dependency for reading JSON encoded data, although my table source doesn't need it.
Cheers, Hung -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
