这里的Kafka怎么实现eventtime

来源：11-2 Flink对接Kafka数据入门

慕用0240705

2023-05-22

Kafka消费怎么实现eventtime 是内置了还是要自己写water mark 分别怎么操作能否讲下

写回答

1回答

Michael_PK

2023-05-28

你这个问题描述的我不完全确定你的含义是啥，你可以具体描述下。

我猜测你的意思是：flink对接kafka的数据，如何基于eventtime消费，是这个意思吗？如果是的话

flink接收到kafka的消息，那么kafka数据中应该有会一个时间字段，在flink中就把这个字段抽取出来作为eventtime，然后加上wm就可以了

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据，Flink助力轻松提薪；尚未入行，让你弯道超车

1000 学习 · 225 问题

相似问题

回答 1

回答 2

回答 1

回答 1

回答 1