apache-pulsar - 现有消息上的 Pulsar-Functions

Question

我是 Apache Pulsar 的新手，但我正在尝试使用 Pulsar-Functions 来处理有关某个主题的现有消息。似乎这些函数仅用于流式传输，因此它们只会在新消息到达输入主题时触发。不过，我还是想确认一下。

谢谢！

Answer 1

是的，你的猜测是正确的。

要回到给定时间的主题并阅读过去的数据，您需要手动使用索引。基本上搜索消息 id 并使用 Reader 界面从那里读取。

还请考虑您可以从主题开始编写消费者消费（您不能使用函数接口和运行时）。