如何重播azure eventhub中的消息

Question

我有一个天蓝色的 eventhub，并且该 eventhub 有多个消费者。检查点可供这些消费者使用。 我想为特定消费者重播消息。我怎样才能实现这个目标？如果是通过更改序列号/偏移值，那么我应该在序列号或偏移值中使用什么数字来重播消息以及我应该在哪里获取这些值？

Answer 1

要重置处理并从每个分区的开头重新启动，您首先需要停止 Function 应用程序。尝试在数据运行时操纵或删除数据并不是一个好主意，并且可能会以意想不到的方式表现出来。

接下来，您需要验证您的 host.json 配置是否未指定 initialOffsetOptions 或将类型设置为“fromStart”。例如：

{
    "version": "2.0",
    "extensions": {
        "eventHubs": {
            "initialOffsetOptions" : {
                "type" : "fromStart",
                "enqueuedTimeUtc" : ""
            }
        }
    }
}  

接下来，您需要删除检查点数据。您最好的选择是删除触发器写入的检查点和所有权 blob。

当您再次启动 Function 应用程序运行时，它不会找到检查点，并将使用“initialOffsetOptions”作为默认起始位置，从每个分区的开头读取。