Kafka中的每个partition都由一系列有序的、不可变的消息组成，这些消息被连续的追加到partition中。partition中的每个消息都有一个连续的序号，用于pa...
发简信
IP属地：浙江
-
Kafka offset管理 -
Flink-Streaming-算子学习-01
概述 系统的学习一下flink的streaming 算子操作，学习一下新的技术，增加一下个人的技术栈储备，java/scala的api； Flink流式算子api官网连接：D...
-
flink 源码分析1之RichSinkFunction
flink sink 2 mysql demo 我们先看一个自定义sink 的demo，将 nc 的数据写入到mysql 中。 RichSinkFunction 的类结构 可...
-
flink基础——简单原理介绍总结来看，流处理是实时的，数据过来，接收后放入缓存，处理节点会立刻从缓存中拉取数据进行处理。批处理则是数据过来，序列化到缓存，并不会立即处理。flink通过引入超时值同时支持...
-
线程-进程间通信（操作系统、java、android）最全总结！
大纲 操作系统进程间通信 进程的通信机制主要有：管道、有名管道、消息队列、信号量、共享空间、信号、套接字。 操作系统线程间通信 线程同步机制是重点 linux中进程间通信和线...
-
java实现Excel表格导出
导出excel学习网址：http://www.cnblogs.com/fx2008/p/3941908.html poi.jar可以操作的EXcel版本？poi.jar中只能...
-
菜鸟笔记(三) - Java Excel报表导入导出本文将介绍Java Poi包的使用,并实现Excel报表的导入导出。 前提摘要：在系统的管理后台当中中，Excel报表的导入导出已经是不不可避免的场景。值得一提的是支付宝和微...
-
MySQL数据库连接超时自动断开的解决方案
最近在将本地的JavaWeb项目部署到服务器上之后遇到的一个奇怪问题 在部署完成后，网站当时可以正常工作，但是第二天访问网站的时候却会遇到一个500 Server Error...
