Kafka延迟到达消息处理



作为Kafka的新手,我们正试图基于以下细节来了解延迟到达记录。请在以下问题上帮助我们。

  1. 要处理延迟到达记录,可以选择什么时间参数来确定我们可以等待延迟到达记录多长时间
  2. 如果当时没有记录,情况会怎样?记录将被丢弃以进行处理
执行时间序列分析的消费者是唯一关心时间的人;卡夫卡没有。

例如,假设您有一个设备在飞行模式下发射某些游戏的指标,它会在本地缓存数据,直到网络重新连接。

在这种情况下,您将收集离线时事件最初发生的时间和记录到达Kafka的时间。

主题仅为附加主题,因此您的分析只能投影数据进入系统时的数据,由您的分析来发现原始事件的最短时间窗口。

最新更新