我的财务朋友小川，上周五，刚刚被升为财务总监，薪资涨了35%！但你一定想不到，他平时从不加班，甚至还经常迟到。领导还给他升职，就是因为：他总能第一时间从销售、运营、市场调研等各类数据中发现问题，抓住业务发展的关键点；!(https://oscimg.oschina.net/oscnet/0f372b4a5

1\.前言ApacheFlink是一个分布式流处理引擎，它提供了丰富且易用的API来处理有状态的流处理应用，并且在支持容错的前提下，高效、大规模的运行此类应用。通过支持事件时间(eventtime)、计算状态(state)以及恰好一次(exactlyonce)的容错保证，Flink迅速被很多公司采纳，成为了新一代的流计算处理引擎。

引言分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时间我们自家的产品RocketMQ(MetaQ的内核)也顺利开源,得到大家的关注。那么,消息中间件性能究竟哪家强?带着这个疑问,我们中间件测试组对常见的三类消息产品(Kafka、RabbitMQ、RocketMQ)做了性

序    工作中用Flink做批量和流式处理有段时间了，感觉只看Flink文档是对FlinkProgramRuntime的细节描述不是很多，程序员还是看代码最简单和有效。所以想写点东西，记录一下，如果能对别人有所帮助，善莫大焉。    说一下我的工作，在一个项目里我们在FlinkSQL基础上构建了一个SQLEngine，

异常是Java程序中经常遇到的问题，我想每一个Java程序员都讨厌异常，一个异常就是一个BUG，就要花很多时间来定位异常问题。什么是异常及异常的分类请看这篇文章：一张图搞清楚Java异常机制(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fmp.weixin.qq

!(https://oscimg.oschina.net/oscnet/ec4f1d7b017a4d73bb1a9d3cd8b5e0ba.png)用了一年时间的TypeScript了，项目中用到的技术是VueTypeScript的，深感中大型项目中TypeScript的必要性，特别是生命周期比较长的大型项目中更应该使用Ty

前言AutoWrapper是一个简单可自定义全局异常处理程序和ASP.NETCoreAPI响应的包装。他使用ASP.NETCoremiddleware拦截传入的HTTP请求，并将最后的结果使用统一的格式来自动包装起来.目的主要是让我们更多的关注业务特定的代码要求，并让包装器自动处理HTTP响应。这可以在构建API时加快开发时间，同时为HTT

第1章Kafka简介1.1kafka起源Kafka是由LinkedIn开发并开源的分布式消息系统，2012年捐赠给Apache基金会，采用Scala语言，运行在JVM中，最新版本1.0.0。1.2kafka设计目标Kafka是一种分布式的，基于发布/订阅的消息系统。主要设计目标如下：①以时间复杂度O(1)的方式提供消息持久化能力，即

  最近要开发dubbo服务，因为以前没用过，其实dubbo服务很简单，网上有很多例子，还有官方文档http://dubbo.io/Homezh.htm，由于新手上路难免遇到各种各样的问题，我就遇到一个问题让我很是费解，百度也没有多少可用的博客，浪费了1天时间，最后找我们技术总监才搞定，这个错误如下：com.alibaba.dubbo.rpc.Rp

!(https://oscimg.oschina.net/oscnet/ab861104b3410776bb22df4a26aa7324216.jpg)从开源免费上传到现在，历时约8个月，活跃安装8000，真是让我大吃一惊。感谢大家的支持！我们开源免费版发布时间比较迟，能得到这个安装成绩，真的非常感谢支持！不要问我数据的真实性，我们没有作假的可