Flink CDC 各位大佬，请问下mysql cdc 2.2.1版，采用StartupOptio

可以设置env.setParallelism(1)，如下：

object FlinkCDCDataStreamApp {

 def main(args: Array[String]): Unit = {
   val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
   env.setParallelism(1)

   val source: DebeziumSourceFunction[String] = MySqlSource.builder()
    .hostname("bigdata00")
    .port(3306)
    .username("root")
    .password("Lvliao521.")
    .databaseList("lv_cdc")
    .tableList("lv_cdc.user")
    .startupOptions(StartupOptions.initial())
    .deserializer(new StringDebeziumDeserializationSchema)
    .build()
   env.addSource(source).print()
   env.execute()
}