Azure活动中心消费组与Kafka消费者组通过春季云流kafka binder
我能够使用Spring Cloud Stream Kafka粘合剂，并将其连接到Azure Event Hubs。我的困惑是关于消费者群体。我给了属性 spring.cloud.bindings。这是否…
Quarkus应用程序在使用Azure事件中心几天后停止工作
我们正面临一个奇怪的问题，几天后使用Azure Event Hubs，Quarkus应用程序停止工作。 我们有一个应用程序，该应用程序可以消费一个事件中心，可以进行…
数据流量分离时，当数据中的任何分区都可以在Azure的Event Hub中进行任何分区
我正在使用带有32个分区的事件中心，并且所有POD都在AKS中部署。我们只有1个开发环境。我想知道是否有任何规定可以将流量引向我们。如果多个开发人员…
如何处理EventProcessorclient错误回调“试图在存储服务中续订所有处理器所有权。”
我实施了一项使用EventProcessorclient组件从Azure EventHub处理事件的服务。 错误回调 private Task OnErrorAsync(ProcessErrorEventArgs args)... …
Azure EventHub消费者
为什么我们需要在EventHub消费者客户端的Azure存储帐户上使用Blob容器（我正在使用Python）。为什么我们不能像我们在kafka中那样直接消耗EventHub（Ka…
可以与Kafka客户端连接到EventHubs
我有一个带有“测试” EventHub的事件中心实例。 我可以连接到此并与本机客户端“ azure.messging.eventhubs”发布消息， 但是当我尝试与contruent.ka…
在调试对Azure组件内部依赖性的调试项目时，我会遇到与分区ID相关的错误
错误指出：“ 例外用户不合适 microsoft.azure.eventhubs.processor.eventprocessorConfigurationException：“遇到错误时，请获取EventHub Partition…
用EventHub触发器在Azure功能中处理重复项
我有一个具有事件轮毂绑定触发器的Azure函数，并且接收了一批EventData。我也有固定的elayretry，可以为未经治疗的例外重试（故意完成）。 如果一个事…
可以在垃圾收集期间调用on_state_changed，请确保关闭或使用上下文管理器
我正在使用Python脚本通过WebSocket协议将API与Azure事件中心连接。当我运行脚本时，将发送数据，直到本文标题中的错误跳出并停止执行脚本。我看不到…
如何防止向JSON字符串添加后斜线
我想使用databricks从EventHub阅读事件，事件的格式为JSON，但它们可以具有不同的架构（这很重要，因为我找到了将架构授予from_json（JSONSTR，schema…
Azure例外 - 斑点存储
我在日志文件中收到以下错误消息。事件中心有Azure配置。 Error occurred in partition processor for partition NONE, com.azure.storage.blob.model…
Azure模式注册表＆＃x2B;火花结构化流＆＃x2B; kafka/eventhub兼容性
有没有一种方法可以将Azure模式注册表与Spark结构化流？ （不是OpenSource模式注册表）。 理想情况下，我会使用一些高级库，例如Abris（ https://gith…
