Netty 线程模型 本篇文章基于Netty 4.1.56.Final Netty的线程模型是Netty高性能的关键。Netty的线程模型关乎于2个类：EventLoopGroup和EventLoop。本篇仅以NioEventLoopGroup和NioEventLoop进...

Netty ChannelPipeline 本篇文章基于Netty 4.1.56.Final 链式结构 Netty的每个channel都会拥有一个ChannelPipeline，ChannelPipeline组织编排了channel的入站和出站数据处理逻辑，是Netty处理...

Flink Task执行之数据流处理流程源码分析 从这里的分析已经知道我们编写的代码最终被封装成Flink Task并在一个while循环中由一个线程中不断执行，本篇文章将进一步了解Flink Task处理数据流的...

Flink AllowedLateness allowedLateness是Flink window中用来容忍一段时间迟到数据的，对allowedLateness最容易的误解是它等同于将watermark减去或者说推迟一段时间，通过推迟窗口触发来容忍...

Kafka-Flink-Kafka End-to-End Exactly-Once End-to-End Exactly-Once 我们知道Flink的checkpoint机制实现了Flink内部的exactly-once语义。而所谓的end-to-end exactly-once即数据从数据源被...

Flink+Disruptor踩坑记 记录一次Flink中使用disruptor的坑，背景是这样的：有一个flink job工作流程是从kafka读取日志数据，经过处理后写入es。写入es的sink采用了disruptor，sink将数据写入...

zookeeper添加kerberos认证 一个3节点的zk集群，3个节点的hostname分别是node01，node02，node03，zk版本3.5.4. 创建3个节点的principle和keytab。 addprinc -randkey zookeeper/node01 add...

最近在用mybatis时发现，将LocalDateTime插入到数据库时时间少了8小时。用网上其他方法试了不少，比如修改mysql时区，都不能解决。最后发现是JDBC连接的参数写错了。 经常在网上看到jdbc连接...