想在Flink DataStream中实现微批,可以做到吗。该如何实现?

比方说基于处理时间,从Kafka 消费数据,每隔5s产生一个Batch,然后对这个Batch处理。

感谢!

回复