Microsoft Azure EventHubs是Azure云中高度可扩展的高吞吐量低延迟持久事件摄取系统。 EventHubs用作应用程序处理具有可变负载配置文件的事件的事件缓冲区。 Microsoft Azure Event Hubs与Apache Kafka或AWS Kinesis相当。这是由Microsoft团队构建和运行的完全托管服务产品。
在eventhub中发布消息时，异常显示为“无法访问已处置的对象。\ r \ n对象名称：'FaultTolerantAmqpObject`1错误”
同时将消息发布到EventHub中。 C＃代码引发异常，例如“无法访问已处置的对象。\ r \ n对象名称：'FaultTolerantAmqpObject`1错误”
我已经配置了事件网格订阅，以在创建资源时针对资源组中的事件启动Web挂接调用。 Web挂钩调用已成功处理，我返回了200。To ...
用分区键（或发布者）编写eventhub连接字符串的正确方法是什么？我应该在EntityPath里面写分区吗？有人可以给我一个例子吗？另外，是否有...
Azure eventhub在python中发送多个float数组消息
我有三个浮点数组数据（A，B，C），我想将其发送到事件中心。这里的问题是类是嵌套的，我不知道如何调整数据的形状以能够发送...
如何使用EventHub ConsumerGroup上的检查点
我正在尝试与Eventhub和消费者群体合作。我的意图是在读取“ n”后存储检查点。但是我找不到办法。如何使用nodejs或Java API执行此操作？如果...
Azure Stream Analytics：计算COUNT（*）超过7天的时间段
我有[Azure事件中心]（https://docs.microsoft.com/en-us/azure/event-hubs/）提取的用户数据流。我正在使用[Azure Stream Analytics]（https：// docs ....
Azure Stream Analytics：在7天内计算COUNT（*）
我有[Azure事件中心]（https://docs.microsoft.com/en-us/azure/event-hubs/）提取的用户数据流。我正在使用[Azure Stream Analytics]（https：// docs ....
在eventhub中，我同时具有“发送者”和“接收者”脚本，用于这两个脚本之间的通信。我面临的问题是，似乎我收到了昨天发送的数据集，外加...
C＃作为Azure事件中心的发送者，而python作为接收者
我有一个连接到Azure事件中心的IoT设备。我试图使该设备与azure数据块通信，并将azure事件中心作为中间件放置在它们之间。问题是...
[我正在尝试部署一个Azure函数，恰好是一个EventHubTrigger，但是我无法运行它，收到以下错误消息：[16-10-2019 11:40:32] Microsoft.Azure.WebJobs.Host：错误...
已启用Kafka的Azure事件中心：接收器中的无效会话超时
我正在尝试使用此处提供的确切代码从启用了Kafka的Azure事件中心发送/接收数据。 https：//github.com/Azure/azure-event-hubs-for-kafka/tree/master/quickstart/dotnet / ...
我有一个网络作业，它从azure事件中心接收网站点击事件，然后将这些事件吸收到ADX中。公共静态异步任务运行（[EventHubTrigger] EventData []事件，ILogger记录器）{// ...
我正在使用Apache Flink，并尝试通过使用Apache Kafka协议从其接收消息来连接到Azure eventhub。我设法连接到Azure eventhub并接收消息，但是我无法使用...
带有EventHubs Kafka使用者的DotNetCore 2.2“接收失败：SSL传输错误”
DotNet Core 2.2应用程序已连接到Azure EventHubs（Kafka）…每周至少一次（从与API相关的Linux服务的输出中，我们确定报告了多个错误：FAIL | rdkafka＃consumer -...
正在将100台设备附加到Azure IoT中心并为每个设备创建一个Azure事件中心是个好主意[关闭]
我想将约100台（更多新来的）设备连接到Azure IoT中心。目前，我试图弄清楚如何组装不同的组件（IoT中心，事件中心，EventHub分区等）。每个...
我正在使用ARM模板创建Eventhub。创建Eventhub时，我没有更新命名空间中的任何属性。到现在为止，它一直在工作，但是突然因错误而失败。 “错误”：{“消息”：“ ...
但是，消费者组将从事件中心检索消息；假设我有1个生产者，32个分区和2个CG，则CG 1将使用不同来源的数据，但需要相同的数据...
是否有一种方法可以限制具有虚拟网络集成的Azure事件中心，以允许从公共入口到特定VNET的入口？] >> [[
我遇到了一个问题，我可以看到它们是我的Azure事件中心上的消息，当我尝试使用流分析将其流式传输到Blob存储时，什么都没有发生。它只是流...
如何在Python中存储azure.eventhub.common.Offset？
根据Azure事件中心的官方文档，管理偏移量是消费者的责任。报价：消费者有责任在...