Azure事件中心偏移量
我已经实现了下面链接中的代码，用于从事件中心接收事件。但是假设有10个事件，每5个事件检查一次。现在程序在读取第7个事件时异常退出，如果我再次重启事件处理器主机，那么事件(1，2，3，4，6)将被重新读取。请建议我如何再次避免重读和阅读第7次事件？任何例子都值得欣赏。谢了。
https://github.com/Azure/azure-event-hubs/blob/master/samples/Java/src/main/java/com/microsoft/azure/eventhubs/samples/Basic/EventProcessorSample.java
共有1个答案
好吧，在事件中心的上下文中，您的工作是处理可能的消息重复，因为事件中心保证至少一次传递，请参阅
Azure 事件中心是否保证至少传递一次？
我们不知道您的场景，因此我们不能建议您构建重复消息检测机制。例如，在将数据发送到事件集线器之前向数据添加唯一id，并让处理器对照已处理消息列表进行检查。
-
关于在物联网场景中使用EventHub的Azure功能，我有几个问题。 EventHub有分区。通常来自特定设备的消息会发送到同一个分区。Azure Function的实例如何分布在EventHub分区中？它是基于性能的吗？如果Azure Function的一个实例设法处理来自所有分区的事件，那么这就足够了，否则每个EventHub分区可能会有一个Azure Function的实例？ 读取偏移量呢
-
我将消息从windows窗体应用程序发送到azure事件中心。在使用数据流分析进行实时操作后，从事件中心获取数据。在该操作之后，我将结果消息发送到事件集线器。现在我想使用移动应用程序（android或windows mobile应用程序）通过azure notification hub向用户显示结果消息。我们可以直接连接azure通知中心和azure事件中心吗？。
-
我对Azure函数的EventHubTrigger有点困惑。 我有一个物联网集线器，我正在使用它与eventhub兼容的endpoint来触发一个Azure函数，该函数将处理和存储接收到的数据。 但是，如果我的函数失败（=抛出异常），在函数调用期间正在处理的消息（或消息）将丢失。实际上，我希望Azure函数运行时在稍后再次处理消息。具体来说，我预计会有这种行为，因为EventHubTrigger正
-
我想将发送到Azure服务总线主题的事件发送到事件中心。这可能吗？ 详细信息：我与我公司的另一个团队合作，该团队接收Azure Service Bus主题的第三方事件（通过webhook），并在不同的应用程序中进一步使用。 我的团队现在希望使用我们现有的事件中心并使用Azure捕获将这些事件存储到存储帐户来收听/订阅此主题。 我做了以下工作： 我在他们的Azure服务总线中创建了他们主题的订阅。我
-
问题内容： 我在Oracle数据库中有一个交易表。我正在尝试为涉及多种交易类型的交付系统收集一份报告。实际上，“请求”类型可以是四个子类型之一（在此示例中为“ A”，“ B”，“ C”和“ D”），而“传递”类型可以是四个不同子类型之一类型（“ PULL”，“ PICKUP”，“ MAIL”）。从“请求”到“交付”之间可以有1到5个事务，并且“交付”类型中的许多也是中间事务。 我需要的是像这样的报