分类： 中间件

Error sending fetch request xxx to node : org.apache.kafka.common.errors.DisconnectException.

这个问题是我在flink任务上报的错, 乍一看是kafka连接出了问题. 推测我们的业务数据量比较大, 集群网络负载比较高, 推测是网络抖动导致的连接超时. ...

05月18日555评论

全文

做监控是个苦差事，不过，没关系，我们可以用 Prometheus 和 Grafana 来轻松搞定 es 集群的监控。凡蜕在这里给大家分享一下详细的步骤，让你们也...

04月27日299评论

全文

使用Logstash处理Kafka中的JSON数据，并使用Python脚本对IP字段进行校验，新增一个check字段表示校验是否成功的步骤如下：安装Logst...

02月11日71

全文

Kafka是由LinkedIn开发的一个分布式基于发布/订阅的消息系统，使用Scala编写，它以可水平扩展和高吞吐率而被广泛使用。安装 Windows 装ka...

02月16日4评论

全文

使用场景异步、削峰、解耦同类比较 ActiveMQ一般都是老项目使用较多，新项目几乎都不会使用。 RabbitMQ 企业中使用的也挺多，功能也挺多。但是er...

08月06日11评论

全文

RPC 什么是 RPC RPC（Remote Procedure Call）—远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术...

07月19日2评论

全文

rocketmq遇到的问题，根本原因是使用了32位的jdk……我一直以为x86是64位的，好傻哦……

07月15日416评论

全文

首先要明确的是，消息队列并不能盲目使用，先说缺点：可用性降低。比如A调用BCD的接口，然后加入了个MQ，如果MQ出问题了可能整个服务就挂了。复杂度增加。增加...

05月30日1评论

全文

Apache JMeter是Apache组织开发的基于Java的压力测试工具。用于对软件做压力测试，它最初被设计用于Web应用测试，但后来扩展到其他测试领域。 ...

05月24日2评论

全文

什么是ehcache 纯Java的进程内缓存，直接在JVM虚拟机中缓存，速度非常快。缓存有两级，内存存储完了自动存到磁盘上。数据可持久化在磁盘上，vm（虚拟机...

04月27日5561

全文