Flink tableapi数据写入kafka

    tableEnv.connect(new Kafka()
      .topic("sensor_sink")
      .version("0.11")
      .property("zookeeper.connect","localhost:2181")
      .property("bootstrap.servers","localhost:9092")
    )
      .withFormat(new Csv())
      .withSchema(new Schema()
        .field("id",DataTypes.STRING())
        .field("temp",DataTypes.DOUBLE())
//        .field("cnt",DataTypes.BIGINT())
//        .field("avg_temp",DataTypes.DOUBLE())
      ).createTemporaryTable("output_table")