当前位置：文江博客话题详情

您能否保证将事件恰好一次发布到事件中心？

发布于 2025-01-12 07:41:44 字数 141 浏览 1 评论 0原文

我知道向消费者传递单个事件中心消息至少一次，并且我可以看到大量与此相关的文档。但是，如果我是事件发布者，是否可以保证我的事件仅发布到流一次？

鉴于我可能无法收到指示发布消息是否成功的响应，我别无选择，只能重试。有什么因素可以阻止我的活动在集线器上重复吗？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

得不到的就毁灭 2025-01-19 07:41:44

不;事件中心生态系统中不保证恰好一次。

也就是说，如果您愿意依赖 Beta 版本，Azure.Messaging .EventHubs 在 v5.7.0-beta.x 中引入了一个新的缓冲生产者，它支持幂等重试。启用此功能后，生产者使用的隐式重试将有助于防止重复。

但是，值得注意的是，这是尽力而为，并且不会改变至少一次保证。无论发布时是否存在重复事件，消费者都应该预期并防止读取重复事件。

要启用它，您需要配置缓冲生产者，类似于：

var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
var eventHubName = "<< NAME OF THE EVENT HUB >>";

var options = new EventHubBufferedProducerClientOptions
{
    EnableIdempotentRetries = true
};

var producer = new EventHubBufferedProducerClient(
    connectionString, 
    eventHubName, 
    options);

有关缓冲生产者的更多信息可以在 < a href="https://github.com/jsquire/azure-sdk-for-net/blob/main/sdk/eventhub/Azure.Messaging.EventHubs/samples/Sample04_PublishingEvents.md" rel="nofollow noreferrer">SDK 的发布事件示例。

尽管我们目前的目标是五月初，但我们还没有确定其稳定版本的具体日期。请注意，我们不建议在关键生产场景中使用 beta 包。

No; there are no guarantees of exactly-once within the Event Hubs ecosystem.

That said, if you're willing to take a dependency on a beta version, Azure.Messaging.EventHubs introduced a new buffered producer in v5.7.0-beta.x which supports idempotent retries. When this feature is enabled, the implicit retries that the producer uses will help to guard against duplicates.

It's important to note, however, that this is best effort and does not change the at-least-once guarantee. Regardless of duplicates when publishing, consumers should expect and guard against reading duplicate events.

To enable it, you'd configure the buffered producer similar to:

var connectionString = "<< CONNECTION STRING FOR THE EVENT HUBS NAMESPACE >>";
var eventHubName = "<< NAME OF THE EVENT HUB >>";

var options = new EventHubBufferedProducerClientOptions
{
    EnableIdempotentRetries = true
};

var producer = new EventHubBufferedProducerClient(
    connectionString, 
    eventHubName, 
    options);

More information on the buffered producer can be found in the Publishing Events sample for the SDK.

We do not yet have a firm date for its stable release, though we're currently aiming for early May. Please be aware that we do not recommend using beta packages in critical production scenarios.

回复收藏 0 原文

~没有更多了~