azure云消息队列 Kafka 版的相关内容

文章 2025-02-18 来自：开发者社区

【Azure Kafka】使用Spring Cloud Stream Binder Kafka 发送并接收 Event Hub 消息及解决并发报错

问题描述根据 Spring Cloud Stream Binder Kafka 发送消息/接收消息的代码示例，只需要配置好 application.yaml 中的 event hub connection string, Event Hub Name就可以正常运行并查看执行结果。但...

文章 2025-01-05 来自：开发者社区

【Azure Event Hub】Kafka消息发送失败(Timeout Exception)

问题描述使用Azure Event Hub，客户端通过kafka发送消息到Event Hub中，规律性的遇见Timeout Exception " send fail; nested exception is org.springframework.kafka.kafkaException: xxx" ...

文章 2024-08-25 来自：开发者社区

【Azure 事件中心】Kafka 生产者发送消息失败，根据失败消息询问机器人得到的分析步骤

问题描述 Azure Event Hubs -- Kafka 生产者发送消息存在延迟接收和丢失问题，在客户端的日志中发现如下异常： 2023-06-05 02:00:20.467 [kafka-producer-thread | producer-1] ERROR com.d...

文章 2024-08-25 来自：开发者社区

【Azure 事件中心】使用Kafka的性能测试工具(kafka-producer-perf-test)测试生产者发送消息到Azure Event Hub的性能

问题描述 Azure Event Hub支持 kafka，所以为了测试消息生产者所在环境与Azure Event Hub之间发送消息的性能如何，特别使用 kafka 官方测试生产者，消费者的性能工具： kafka-producer-perf-test.bat kafka-consumer-perf-test.bat (.bat...

文章 2024-08-25 来自：开发者社区

【Azure 事件中心】使用Apache Flink 连接 Event Hubs 出错 Kafka error: No resolvable bootstrap urls

问题描述参考Github上 Event Hub的示例代码（Using Apache Flink with Event Hubs for Apache Kafka Ecosystems : https://github.com/Azure/azure-event-hubs-for-kafka/tree/master/tutorials/flink），使用Apache Flink kafk...

文章 2024-08-25 来自：开发者社区

【Azure 应用服务】部署Kafka Trigger Function到Azure Function服务中，解决自定义域名解析难题

问题描述经过前两篇文章，分别使用VM搭建了Kafka服务，创建了Azure Function项目，并且都在本地运行成功。【Azure Developer】在Azure VM (Windows) 中搭建 kafka服务，并且通过本地以及远程验证发送+消费消息【Azure 应用服务】本地创建Azure Function Kafka Trigger 函数...

文章 2024-08-25 来自：开发者社区

【Azure 应用服务】本地创建Azure Function Kafka Trigger 函数和Kafka output的HTTP Trigger函数实验

问题描述在上一篇博文(https://www.cnblogs.com/lulight/p/16525902.html)中，我们成功的以VM作为Kafka服务器运行，并且验证了从其他机器中远程访问。在本文中，将使用Visual Studio 2022创建Azure Function 作为生产者和消费者在本地进行验证生产者：使用HTTP Trigger函数，以 kaf...

文章 2024-08-25 来自：开发者社区

【Azure Developer】在Azure VM (Windows) 中搭建 kafka服务，并且通过本地以及远程验证发送+消费消息

问题描述查看了 “How to Install and Run Apache Kafka on Windows? ” 一文后，成功安装了Kafka服务，但是如何使用呢？如何在其他机器上连接到服务呢？如何发送消息，消费消息呢...

文章 2024-08-25 来自：开发者社区

【Azure 事件中心】使用Kafka消费Azure EventHub中数据，遇见消费慢的情况可以如何来调节呢？

问题描述使用Kafka消费Azure EventHub中数据，遇见消费慢的情况可以如何来调节呢？问题解答查看Kafka Consumer的配置参数，其中最只要的一个参数为：max.poll.records，表示Consumer每次调用poll()时取到的records的最大数。一般情况，在增加max.poll.records后，能让消费速度起...

文章 2024-08-25 来自：开发者社区

【Azure 事件中心】开启 Apache Flink 制造者 Producer 示例代码中的日志输出（连接 Azure Event Hub Kafka 终结点）

问题描述 Azure Event Hub 在标准版以上就默认启用的Kafka终结点，所以可以通过Apache Kafka协议连接到Event Hub进行消息的生产和消费。通过示例代码下载到本地运行后，发现没有 Kafka Producer 的详细日志输出。当查看SDK源码中，发现使用的是 org.slf4j.Logger 输出日志，如： ...