hi,all:
  event time这个时间戳是在什么时候打到数据上面去的,看api是在flink 
source收到数据之后再标注的,并不是真正的数据源携带过来的(比如手机终端)?使用kafka 
source的话根据文档的定义kafka携带的时间戳也仅仅是kafka收到数据的时候打上的时间戳。
  
那么有个问题:以kafka为例,数据到队列的时候按「顺序」打上时间戳,那么如果数据是「乱序到达」的也被打上了「递增的时间戳」,后续基于event-time的处理都是基于这个时间戳来进行,那不就丧失了真实世界的定义吗?
  不知道有哪里是我理解不对的地方望指教!
  祝好~

回复