Microsoft Azure EventHubs是Azure云中高度可扩展的高吞吐量低延迟持久事件摄取系统。 EventHubs用作应用程序处理具有可变负载配置文件的事件的事件缓冲区。 Microsoft Azure Event Hubs与Apache Kafka或AWS Kinesis相当。这是由Microsoft团队构建和运行的完全托管服务产品。
我正在使用来自 Azure 事件中心的事件，并且需要将事件负载记录为字符串。有效负载采用 JSON 格式。 私有只读EventProcessorClient _eventProcessor； _事件处理器。
EventHubProducerClient可以跨多个请求重用吗
我正在利用 Azure SDK 的服务将遥测数据记录到 Azure 事件中心。我的客户端应用程序调用一个 API 端点，该端点实例化 EventHubProducerClient 以将数据记录到事件 H...
EventHubTrigger EventData[] 绑定不起作用
我正在创建一个由 EventHub 触发的 C# 隔离工作进程 Azure 函数，该函数会将带有标头的 EventData 列表输出到另一个 EventHub 中。 当使用 str...
Strimzi kafka mirrormaker2 Azure eventhubs 启动时出错
我正在通过 Strimzi 设置 KafkaMirrorMaker2 并尝试将 kafka 主题镜像到 Azure eventhubs 。我能够让它在我在 Azure 和
更改事件中心和使用者组后，事件中心源连接器抛出“无效偏移”错误
我的设置中有一个事件中心源连接器，它最初指向命名空间内的单个分区事件中心。最近，我们决定迁移到新的事件中心，增加了
如何将 Json 和 Avro 格式事件发送到 Azure 事件中心并最终将它们引入 Azure 数据资源管理器表。使用 .Net (c#)
我的要求是使用 Azure 事件中心捕获 Json 和/或 Avro 格式的事件，并最终将这些事件提取到 ADX 中。也不想将这些事件捕获到 Blob 存储中...
在 Azure 事件中心的单个消费者组上是否可以有多个具有自己检查点的读取进程
在我们的场景中——我们正在轮询一个本地数据库，并使用 REST 端点每 2 分钟将数据发布到事件中心 我们正在尝试将多个实体推送到同一个事件中心......
使用 Dapr 的应用程序连接到两个不同的事件中心，每个事件中心都有不同的消费者组名称
我是 Dapr 的新手。我有一个 Azure 容器应用程序应用程序，它需要从两个不同的 Azure 事件中心接收事件，每个事件中心具有不同的使用者组名称。这可能吗？...
如何在 azure event hub 上使用 prem 上的 kafka 消息？
我想在 azure 事件中心中使用来自已经存在的 prem kafka 服务的 kafka 消息。 我有 topic 和 brokerlist 。 我找不到我应该在事件中配置它们的位置......
使用 python 订阅 Azure Event Hub 中的多个分区
我创建了一个事件中心命名空间。 在事件中心命名空间内，我创建了一个具有 8 个分区的事件中心。 它有一个消费者组——$Default。 我已经用 python 编写了接收器代码...
导入 EventHubManagementClientOptionalParams 返回错误
打字稿。 我使用“@azure/arm-eventhub”：“^3.2.0”， 并且想要 从 @azure/arm-eventhub 导入 { EventHubManagementClient, EventHubManagementClientOptionalParams }; 返回'
我正在 Azure 事件中心存储一些应用程序生成的消息，这些消息由 Web 应用程序生成，我想在 Rest API 调用中从 Azure 事件中心检索这些消息以显示...
Azure 事件中心：批量接收事件，这些事件作为单独的消息发送到中心？
我有以下模式， Http 触发器功能应用 -> 事件中心 -> 事件中心监听器功能应用 不幸的是，HTTP 触发器应用程序的发送者发送了许多单独的请求，这意味着
Azure 诊断设置在向事件中心发送数据时使用的分区键是什么？
在为 Azure 中的资源配置诊断设置并将该诊断设置配置到事件中心时，将消息发布到事件中心时使用的分区键是什么？...
我正在升级项目中的新包。从 Microsoft.ServiceBus.Messaging 到 Azure.Messaging.EventHubs。所以我们将 EventData 转换为 byte[]。 在 Microsoft.ServiceBus.Mess 中...
使用 Azure Event Hub Kafka 连接 Azure VM 上的独立 Flink 集群
我用 Ubuntu 操作系统创建了一个 Azure VM，我在其中安装了 Flink 1.16.1 及其所有先决条件。 VM 位于 VNet 中。 在另一边，我有一个用于 Apache Kafka 的 Azure 事件中心，它是
如何使用@EventHubTrigger注解在Spring Boot编写的Azure Function中接收Avro Events？
这是包含@EventHubTrigger注解的类 包com.function； 导入 com.microsoft.azure.functions.*; 导入 com.microsoft.azure.function.annotation.*; 导入 java.util.Optio...
如何通过 TypeScript 将 EventhubNamespace TLS 版本设置为 1.2
我有一个要求将eventhub的TLS版本升级到1.2。 事件中心是由打字稿创建的。 像这样： EventhubNamespaceService.ts 从'@azure/...导入{EventHubManagementClient}
我们如何使用 Azure Databricks (Pyspark) 使用 Azure AD 服务主体使用来自 azure 事件中心的事件中心？
我需要一些代码片段的帮助，这些代码片段用于使用 PySpark 和 Azure AD 服务主体来使用来自 Azure EventHubs 的事件。 （我不想为此使用 scala） 附言 结构...
我有一个 Azure EventHub EH1 设置了一个 ConsumerGroup CG1。我还有一个应用程序 A1，它使用 CG1 从 EH1 读取数据。 为了弹性，我有另一个相同应用程序的独立副本 A2 dep ...