消息发送流程：!这里写图片描述(https://imgblog.csdn.net/20180905170801267?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FudXJub21lcnU/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA/disso

本次分享来自阿里巴巴的工程师在ApacheKafkaxApacheFlink·北京会议上的分享，关于Apache Flink结合ApacheKafka实现端到端的一致性语义的原理。2017年12月Apache Flink社区发布了1.4版本。该版本正式引入了一个里程碑式的功能：两阶段提交Sink，即TwoPhaseCommitSin

一.StreamingContext详解有两种创建StreamingContext的方式：valconfnewSparkConf().setAppName(appName).setMaster(master);valsscnewStreamingContext(conf,S

线上某服务A调用服务B接口完成一次交易，一次晚上的生产变更之后，系统监控发现服务B接口频繁超时，后续甚至返回线程池耗尽错误ThreadpoolisEXHAUSTED。因为服务B依赖外部接口，刚开始误以为外部接口延时导致，所以临时增加服务Bdubbo线程池线程数量。配置变更之后，重启服务，服务恢复正常。一段时间之后，服务B

packagecom.konka.dsp;importorg.apache.flink.api.common.JobExecutionResult;importorg.apache.flink.api.common.restartstrategy.RestartStrategies;import

框架简介主要定位于互联网企业架构，已内置企业信息化系统的基础功能和高效的代码生成工具，包括：系统权限组件、数据权限组件、数据字典组件、核心工具组件、视图操作组件、工作流组件组件、代码生成等。采用分层设计、双重验证、提交数据安全编码、密码加密、访问验证、数据权限验证。平台简介    是一个分布式的框架，提供项目模块化、服务化、热插拔的思想，高

消费者再平衡操作消费者连接器的核心处理逻辑是再平衡操作，它起了承上启下的作用。初始化消费者连接器只是“创建了队列和消息流”，再平衡操作会“为消费者重新分配分区”。只有为消费者分配了分区，拉取线程才会开始拉取分区的消息。因为分区要被重新分配，分区的所有者都会发生变化 ，所以在还没有重新分配分区之前 ，所有消费者都要停止已有的拉取钱程 。

内置功能(只列了一部分功能)1.用户管理：用户是系统操作者，该功能主要完成系统用户配置。2.机构管理：配置系统组织机构（公司、部门、小组），树结构展现，可随意调整上下级。3.区域管理：系统城市区域模型，如：国家、省市、地市、区县的维护。4.菜单管理：配置系统菜单，操作权限，按钮权限标识等。5.角色管理：角色菜单权限分配、设置角色按机构进行

作为技术人员tcpdump这个工具还是有必要了解的当你遇到网络协议问题一筹莫展的时候，这时候往往可以通过tcpdump来看网络的通讯过程中发生了什么事。本文只介绍工作用遇到的问题供大家参考，旨在给你工作中遇到类似问题提供解决灵感，具体tcpdump怎么使用google吧。下面通过三个案例进行介绍：案例一：flume写kafka日志报错案例二：LB（负载均衡）增加请求header后，nginx日志获取不到headerkeyclient_ip案例三：mysqlQPS特别高，但mysql并没有慢查询，想知道topKmysql语句最后：场景的http协议抓包场景