7

设想

我在 2018 年 1 月 1 日创建了一个 eventthub。

我的 eventthub 保留期设置为 1 天。

我启用“捕获”,保留每 5 分钟或 300 mb 的默认捕获参数,特征并存储在名为“ customerevents ”的容器中

截至今天,2018 年 10 月 22 日,我向我的 eventthub 发送并处理了 1000,000 个客户事件。

我为另一个对历史数据感兴趣的部门创建了一项新服务,现在需要重播自 2018 年 1 月 1 日以来我收到的所有1000,000 条消息。

我的customerevents存储容器中有很多很多“文件夹”,用于年/月/日,每 5 分钟一次,每个.avro文件中包含我捕获的事件。

我如何为我的新服务“重播”所有这些事件?

任何建议表示赞赏。

4

0 回答 0