Microsoft Azure EventHubs是Azure云中高度可扩展的高吞吐量低延迟持久事件摄取系统。 EventHubs用作应用程序处理具有可变负载配置文件的事件的事件缓冲区。 Microsoft Azure Event Hubs与Apache Kafka或AWS Kinesis相当。这是由Microsoft团队构建和运行的完全托管服务产品。
我正在使用 Java 17 监听来自 Azure 事件中心的事件。我只有连接字符串和事件中心名称。根据微软文档，我可以这样做：
使用 NSubstitute 模拟 Azure 函数中的 EventHubAsyncCollector
我得到了一个简单的Azure函数： [函数名（“测试函数”）] 公共异步任务运行（[CosmosDBTrigger（ 数据库名称：“测试”， 容器名称：“测试”，
使用托管身份访问 Spark Streaming 中的 Eventhub
我有一个要求，我需要访问 Spark Streaming（天蓝色数据砖）中的 eventhub 流，但使用托管身份验证。目前我在所有BL中只看到SAS密钥访问...
将数据从增量表写入事件中心的流作业在数据块中失败 - 超时问题
这里是我的代码，用于将数据从增量表写入事件中心（消费者团队将从这里消费数据）： 导入 org.apache.spark.eventhubs._ 导入 org.apache.spark.sql.streaming.Trigger._...
事件中心和 Azure for Kafka 中的 Hdinsight 有什么具体区别？
我正在开发一个应用程序，我需要在 Hdinsight 和事件中心之间进行选择。我在互联网上进行了全面搜索，但找不到它们之间的任何具体比较。我想要...
将 Azure 函数 EventHub 触发器升级到编程模型 v4 时出错。这是否与缺少设置“dataType”：“binary”有关？
我正在尝试将我的 Azure 函数从 v3 迁移到 v4 编程模型。如果我尝试触发重构函数，我会收到以下错误： [2023-10-24T08:05:30.375Z] 执行 '
EventHubTrigger 与 EventData[] 绑定不起作用
我正在制作一个由 EventHub 触发的 C# 独立工作进程 Azure 函数。 该函数在使用 string[] 绑定时运行良好，但当我使用 Azure.Messag 中的绑定 EventData 时...
如何通过在yaml文件中设置spring来关闭kafka的azure事件中心
我试过了，但没有帮助 春天： 自动配置： 排除： - org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration - org.springframework.boot.actuate.autoconfigure.metrics。
即使没有新数据，我们如何强制 Databricks 结构化流每隔几秒从事件中心读取数据？
我们使用 Databricks 结构化流从 azure 事件中心读取数据，并使用 forEachBatch 将数据更新插入到 writeStream 部分中的增量表中 问题是 - 事件...
我有关于 Azure 事件中心的问题。您可以使用 MS Graph API 从现有的 Azure 事件中心获取相关数据吗？ （出于报告目的，创建自定义仪表板） 我的活动中心很少
使用结构化流 pyspark 中记录的步骤，我可以创建连接但无法读取数据。下面是错误获取 错误： 流停止了... java.util.concurrent.
我有一个 NodeJS azure 函数，它从 EventHubA 接收一批事件。它对各个事件进行一些处理，大约需要 3 秒，并将新事件发送到 EventHubB。 我是...
如何在流分析中的 FROM 子句中不仅仅基于 TIMESTAMP 创建时间窗口？
我的用户可以执行两项操作： 进入房间 离开这个房间 我正在使用 Azure 流分析，我的目标是创建一个进入房间但未将其留在下一个房间的用户表...
将大于 256k 的 EventData 发送到 Azure Eventhub
我需要发送一些数据到eventhub，但是由于大小太大而没有发送。有没有办法压缩数据或使用某些命令将数据分块并将其加入事件中心？...
是否有一个 docker 映像可以在测试或 CI 环境中代替 Azure 事件中心运行？
是否有 docker 映像可以在测试或 CI 环境中代替 Azure 事件中心运行？ 我希望能够建立一个完整的堆栈，并将模拟事件中心作为 Docker 容器运行，怎么样...
如何处理来自具有不同表日志结构的azure不同资源的诊断日志？
我正在尝试通过 EventHub 将特定订阅的不同 azure 资源的诊断日志发送到 Log Analytics Workspace(LAW)。 但由于我们有不同的 azure 资源日志，每个资源
我正在开发一个Azure EventHub函数触发器来批量消费消息。我想了解以下两件事。 事件中心触发器中是否有默认的重试策略/机制...
从 Azure 事件中心监听时，我收到错误 提供的偏移量 XXXXX 无效。系统中的最后一个偏移量是 XXXXX 分区 1 上出现错误：AMQP 对象会话已中止。
MS graph api：使用 Azure 事件中心订阅有关组更改的通知
基本上我正在尝试订阅有关组更改的通知，以便调整第三方系统中的授权，请找到下面的代码。它使用 Java 的 graph sdk。我已经添加了
我正在编写一个非常基本的 Python 脚本，该脚本假设将示例 JSON 数据发送到 Azure 事件中心。 这是我的脚本： 导入异步 从 azure.eventhub.aio 导入 EventHubProducerClient