Microsoft Azure EventHubs是Azure云中高度可扩展的高吞吐量低延迟持久事件摄取系统。 EventHubs用作应用程序处理具有可变负载配置文件的事件的事件缓冲区。 Microsoft Azure Event Hubs与Apache Kafka或AWS Kinesis相当。这是由Microsoft团队构建和运行的完全托管服务产品。
使用 spring boot kafka 连接事件中心时出错
我有一个 spring boot 应用程序，它使用 spring-kafka 连接到 azure 事件中心（启用了 kafka）； 这些是 SASL 消费者属性： props.put(CommonClientConfigs.SECURITY_PROTOCOL_CON...
在这种情况下，我们需要将已登陆 Azure 事件中心的消息发送到外部 Kafka 主题中的主题。没有转换，只是从 AEH 读取事件并转发给 Kafka ...
我的 eventhub 有四个分区，一个分区一直出现以下错误，而其他分区工作正常： 2023-03-21 17:50:19 警告 [azure.eventhub._eventprocessor.event_processor][340]：
我正在使用官方教程使用 BlobCheckpointStore 为 azure eventhub 做检查点： https://learn.microsoft.com/en-us/python/api/overview/azure/eventhub-checkpointstoreblob-readme?view=...
如何在 C# 中为事件总线创建接收器以获取给定时间跨度的消息？
使用 Azure.Messaging.EventHubs.Consumer； 使用系统文本； 字符串连接字符串 = ""; 字符串 eventHubName = ""; 字符串 consumerGroup = EventHubConsumerClient.
我正在尝试使用 json 配置和 Bicep 创建一个 Azure 事件中心。 事件中心命名空间部署良好，但是当我尝试将代码扩展到命名空间/事件中心和命名空间/事件中心/
我使用“spring-cloud-azure-stream-binder-eventhubs”进行事件中心开发。现在我和消费者打交道，可能会出现一些业务异常。 我的配置 溪流： 功能：...
Azure Function v4 .net6 事件中心触发器 - 如何获取 EnqueuedTimeUTC？
我有一个可用的 Azure Functions 应用程序，带有一个事件中心触发器。 它使用 Microsoft.Azure.Functions.Worker 1.10、函数运行时 4、.Net 6 并作为隔离（非进程内）运行。 当前
我们有以下设置： 事件中心 —> Azure 函数 —> API。 我们正在尝试使用 Event Hub 提出死字解决方案。事件中心不附带 Dead Lettering，因此......
当我在 Spring Boot 中使用服务主体将事件发送到事件中心应用程序的反应方式时，出现错误 “amqp:unauthorized-access”错误描述“未经授权
使用 Kafka 驱动程序从 Azure 事件中心读取似乎没有获得任何数据
我在 Azure Databricks python 笔记本中运行以下代码： 主题 = "myeventhub" BOOTSTRAP_SERVERS = "myeventhubns.servicebus.windows.net:9093" EH_SASL = "kafkas...
从分区的EventHub消费以避免QuotaExceededException的正确策略是什么？
我是通过 Java EventHubClient 实现从 Azure EventHub 实例进行消费。我的策略是为每个分区创建并持久化一个PartitionReceiver，然后调用...
Azure Eventhub Python - OWNERSHIP_LOST(所有权丢失)
我已经复制粘贴了这个脚本，它工作良好。我从eventhub获取所有事件： import logging from azure.eventhub import EventHubConsumerClient connection_str = '<< CONNECTION ...
闲置时在 Azure.Messaging.EventHubs.EventProcessorClient 上更新 EventHub Partition Offsett 检查点。
在我的方案中，我会有一批事件同时发生，然后在很长一段时间内EventHub会处于空闲状态。在我的处理器客户端中，我想每隔N个事件或N分钟检查一次。
使用 Azure EventHostProcessor Receiver 时，从事件枢纽接收到的垃圾值。
我正在使用Qpid-Proton-0.10(Python)--基于AMQP 1.0的消息传递库，向Azure Event Hubs发送数据。为了接收数据，我按照以下指南使用EventProcessorHost：https:/azure.microsoft...。
我使用这个RedDog工具生成了一个SAS签名，并使用Events Hub API refs成功向Event Hub发送了一条消息。我知道它是成功的，因为我得到了一个201创建的响应从......
在EventProcessorClient中，分区租约所有权管理如何工作？有一篇文章有高层次的描述，但我想了解更多的细节，比如租约管理、定时、 ...
我最近把我的.NET框架项目转移到了.NET Core 3.1 我发现以下属性没有找到： ErrorTrigger，TraceFilter，EventHubTrigger，ConsumerGroup谁能告诉......
我正在使用.net core 3.1编写一个 azure webjob，我得到了以下运行时异常。InvalidOperationException: %EventHubName% does not resolve to a value.我的触发器看起来是这样的。...
我开始开发一个向事件枢纽发送消息的 Azure Function。使用Azure Event Hubs上提供的Azure Functions的输出绑定的例子，我能够用 ...