Spring Cloud Stream 与 Azure EventHubs 和 TokenCredential
如何使用Azure Tokencredential使用Azure-Spring-cloud-stream-binder-eventhubs来消费EventHubs的数据。默认选项是使用连接字符串，但我没有。我有客…
RejectedExecutionException：ReactorDispatcher 实例已关闭。 - Azure 事件中心和数据块火花
我正在尝试使用 Databricks PySpark 使用来自 Azure 事件中心的数据并将其写入 ADLS 接收器中。不知何故，spark 作业无法完成并在运行 2 小时后中止。…
Event Hub Premium - 处理单元估算
我只是想知道是否有任何好方法来估计 Event Hub Premium 中特定配置所需的处理单元数。假设我知道数据输入/输出量、入口/出口消息数量，我如何估计 PU…
压缩消息未显示在 eventhub 中
我正在使用 GZIP 压缩器来压缩消息，并尝试将数据从控制台应用程序推送到 eventhub。当我将消息推送到 eventhub 时，它不会抛出任何异常，同时数据也…
Apache Spark 上的 Databricks AttributeError: 'str'对象没有属性“_jvm”；
当尝试使用 Apache Spark 上的 Databricks 从 Azure 事件中心读取流数据时，出现错误 错误 AttributeError: 'str' object has no attribute '_jvm' 的…
Databricks 连接到 Azure 事件中心的 Apache Spark Streaming 连接字符串错误
我收到错误： Exception: ERROR: 'int' object has no attribute 'value' AttributeError: 'str' object has no attribute '_jvm' ehConf['eventhubs.…
Kubernetes MirrorMaker2 无法加载 Secret
我有一个奇怪的问题，没有人能指出。为了确保这不是 Azure Kubernetes 问题，我还启动了 minikube 在本地进行测试，但遇到了相同的错误。共同点是 Mir…
事件中心限制并显示错误：请求因实体受到限制而终止。错误代码：50002。子错误：102
我正在使用 Databricks Labs 数据生成器将合成数据发送到事件中心。 大约两分钟内一切似乎都工作正常，但随后流媒体停止并提供以下错误： The request…
升级到 .Net 6 和 Fuctions 4 后，EventData JSON 反序列化错误
我正在将带有 Functions v3 的 .Net 3.1 升级到带有 Functions v4 的 .Net 6，并且我有这个 EventHubTrigger： [EventHubTrigger("clean-station-kfi-…
Azure EventHub 消息排序
我有一个事件中心触发器，已将其配置为侦听事件中心的消息。在发送端 javascript 脚本中，我按如下方式初始化客户端 const client = new EventHubProd…
IotHub>EventHub>FA是否存储发送消息的顺序
场景如下： Device1 一次发送两条 iothub D2C 消息： 将标志设置为 true 将标志设置为 false Iot 消息路由将消息路由到 eventhub，这将触发 EventHubT…
有没有办法将数据从 AWS Kinesis 发送到 Azure 事件中心？
我的公司正在对一些流数据进行 POC，其中一项任务是将数据从 AWS Kinesis 发送到 Azure 事件中心。 以前有人尝试过做这样的事情吗？ 我正在考虑使用 l…
如何使用 Azure 二头肌设置 EventHub discoveryRecoveryConfigs？
我创建了一个模块“resources.bicep”来在两个区域中创建事件中心命名空间。 resource eventHubNamespace 'Microsoft.EventHub/namespaces@2021-11-01…
如何从 Azure Function Event Hub 触发器将 CosmosDB 依赖项跟踪数据发送到 Application Insights
我有一个由 eventhub 触发并批量发送数据的 Azure 函数。在函数内部，有多个调用将数据插入到 CosmosDB 中。我添加了以下代码作为 App Insight 监控的…
如何查看按消费者组分组的 Azure 事件中心指标？
我有一个 Azure 事件中心主题，有两个消费者组监听该主题。其中一个消费者正在努力从主题中检索数据，但另一个消费者成功地检索了数据。为了解决陷入…
