我很难理解apachekafka中事件时间和处理时间的区别。例如,apache flink使用水印,在发出水印之前,时间不会与实际的挂钟时间同步。只有在这之后,时间才会进步(我希望我是对的)。我知道Kafka不使用水印。我仔细阅读了文档,但除了在事件上加盖事件发生的时间或事件处理的时间之外,找不到任何关于Kafka中处理时间的信息。在Kafka事件处理中,这些概念仅仅是概念层面的吗?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!