Re: Flink+DDL读取kafka没有输出信息,但是kafka消费端有信息

2021-01-05 Thread Arvid Heise
Note that you posted to the english speaking mailing list. For the Chinese-speaking version please use user...@flink.apache.org. On Thu, Dec 24, 2020 at 3:39 PM Appleyuchi wrote: > 是Flink1.12的,kafka消费端能读取到数据,但是下面的代码无法读取到数据,运行后没有报错也没有输出, > 求助,谢谢 > > > import

Flink+DDL读取kafka没有输出信息,但是kafka消费端有信息

2020-12-24 Thread Appleyuchi
是Flink1.12的,kafka消费端能读取到数据,但是下面的代码无法读取到数据,运行后没有报错也没有输出,求助,谢谢 import org.apache.flink.streaming.api.scala._ import org.apache.flink.table.api.{EnvironmentSettings, Table} import org.apache.flink.table.api.bridge.scala.StreamTableEnvironment import org.apache.flink.types.Row import