Re: Is CSV format supported for Kafka in Flink 1.10?

2020-03-01 Thread Jark Wu
-1.10.0-sql-jar.jar On Sun, 1 Mar 2020 at 03:48, kant kodali wrote: > Hi, > > Is CSV format supported for Kafka in Flink 1.10? It says I need to specify > connector.type as Filesystem but documentation says it is supported for > Ka

Is CSV format supported for Kafka in Flink 1.10?

2020-02-29 Thread kant kodali
Hi, Is CSV format supported for Kafka in Flink 1.10? It says I need to specify connector.type as Filesystem but documentation says it is supported for Kafka? import org.apache.flink.contrib.streaming.state.RocksDBStateBackend; import org.apache.flink.runtime.state.StateBackend; import