问题情形 使用Java SDK编写的Event Hub消费端应用，随机性遇见了某个分区没有消费消息的情况，在检查日志时候，有发现IdelTimeExpired的错误记录。在重启应用后，连接EventHub正常，并又能正常消费数据。比较怀疑的方面，在又开启Retry机制的情况下，为什么分区 Partition 连接断掉后没有重连呢 错误消息： 消费端代码： 分析原因 第一步，需要根据日志来判断当前分 ...
2020-09-21 11:47 1 489 推荐指数：
问题描述 使用EFK（Elasticsearch, Fluentd and Kibana）在收集日志的解决方案中， 可以先把日志发送到EventHub中，然后通过Logstash消费EventHub中的事件并分发出去。但是在使用Logstash的过程中，遇见了连接不上EventHub的错误 ...
上篇博文中，我们介绍了Azure Event Hub的一些基本概念和架构： Azure Event Hub 技术研究系列1-Event Hub入门篇 本篇文章中，我们继续深入研究，了解Azure Event Hub的创建、编程SDK，实现将事件发送到云端的Azure Event Hub ...
上篇博文中，我们通过编程的方式介绍了如何将事件消息发送到Azure Event Hub： Azure Event Hub 技术研究系列2-发送事件到Event Hub 本篇文章中，我们继续：从Event Hub中接收事件。 1. 新建控制台工程 EventHubReceiver 2. 添加 ...
前两个系列研究了Azure IoT Hub和Azure Messaging。最近准备继续研究Azure Event Hub，即Azure的事件中心。首先， Azure Event Hub的官方介绍： 1. Azure 事件中心是超大规模的遥测引入服务，可收集、传输和存储数以百万的事件 2. ...
上篇博文中，我们介绍了Azure IoT Hub的使用配额和缩放级别： Azure IoT 技术研究系列4-Azure IoT Hub的配额及缩放级别 本文中，我们比较一下Azure IoT Hub和Event Hub，同时启动Azure Event Hub(事件中心)的研究。 Azure ...
问题描述 事件中心提供 Kafka 终结点，现有的基于 Kafka 的应用程序可将该终结点用作运行你自己的 Kafka 群集的替代方案。 事件中心可与许多现有 Kafka 应用程序配合使用。在Azure官方提供的Demo中，都是针对Global Azure。以下内容通过实验来一步一步调试并在 ...
1、 参考：https://bbs.pinggu.org/thread-4662247-1-1.html ...
最近几天在做spark数据同步过程中，中间通过kafka集群处理消息，每次同步到一半就会出现同步不了 查看日志如下： 最开始看到这个问题很懵逼，完全找不到解决问题的切入口，期间也询问了架构师-因为这个kafka和spark都是他引进来的，同时也问了运维同事，有没有碰到这个问题，最后都是无法 ...
