Hi Danny, Thanks for quick reply. I replace the flink planner to blink planner deps in the kafka-connector pom file, and run the unit test. It throws errors which I found in class KafkaTableSourceSinkFactoryBase, it use SchemaValidator class which only exists flink-planner, not blink-planner.
Thanks, Kaka Chen Danny Chan <yuzhao....@gmail.com> 于2019年7月16日周二 下午4:53写道： > How do you use the Kafka connector, through the TableEnvironment#sqlUpdate > (the DDL), or through the TableEnvironment#connect() (the table api) ? > > Best, > Danny Chan > 在 2019年7月16日 +0800 PM4:41，kaka chen <kaka11.c...@gmail.com>，写道： > > Hi All, > > > > We are trying to switch to blink table planner in Kafka's connector, but > > found there is no SchemaValidator and related classes, how to resolve it? > > Thanks. > > > > Thanks, > > Kaka Chen >
