Kafka中的每个partition都由一系列有序的、不可变的消息组成,这些消息被连续的追加到partition中。partition中的每个消息都有一个连续的序号,用于pa...

Kafka中的每个partition都由一系列有序的、不可变的消息组成,这些消息被连续的追加到partition中。partition中的每个消息都有一个连续的序号,用于pa...
概述 系统的学习一下flink的streaming 算子操作,学习一下新的技术,增加一下个人的技术栈储备,java/scala的api; Flink流式算子api官网连接:D...
flink sink 2 mysql demo 我们先看一个自定义sink 的demo,将 nc 的数据写入到mysql 中。 RichSinkFunction 的类结构 可...
总结来看,流处理是实时的,数据过来,接收后放入缓存,处理节点会立刻从缓存中拉取数据进行处理。批处理则是数据过来,序列化到缓存,并不会立即处理。flink通过引入超时值同时支持...
大纲 操作系统进程间通信 进程的通信机制主要有:管道、有名管道、消息队列、信号量、共享空间、信号、套接字。 操作系统线程间通信 线程同步机制是重点 linux中进程间通信和线...
导出excel学习网址:http://www.cnblogs.com/fx2008/p/3941908.html poi.jar可以操作的EXcel版本?poi.jar中只能...
本文将介绍Java Poi包的使用,并实现Excel报表的导入导出。 前提摘要:在系统的管理后台当中中,Excel报表的导入导出已经是不不可避免的场景。值得一提的是支付宝和微...
最近在将本地的JavaWeb项目部署到服务器上之后遇到的一个奇怪问题 在部署完成后,网站当时可以正常工作,但是第二天访问网站的时候却会遇到一个500 Server Error...
本次的项目环境为 SpringBoot 2.0.4, JDK8.0. 服务器环境为CentOS7.0, Nginx的忘了版本. 前言 SpringBoot使用MultiPar...
今天我司线上kafka消息代理出现错误日志,异常rebalance,而且平均间隔2到3分钟就会rebalance一次,分析日志发现比较严重。错误日志如下 这个错误的意思是,消...
Spring Boot Test Spring Boot提供了一些注解和工具去帮助开发者测试他们的应用。相较于SpringBoot1.3,SpringBoot1.4对测试有了...
转载请注明出处spring boot 实例之 用户登录--碧波之心简书 上两篇完成了用户信息表的增删查,接下来增加用户登录功能。采用spring security来进行权限控...
本文针对Redis以及redis的几种集群方案的调研日期在2016年8月,后续如果各框架有更新与本文不符,请自行甄别。 Redis回顾 Redis支持的数据结构 字符串(St...
JStorm:1、概念与编程模型JStorm:2、任务调度 转载自个人博客示例功能说明:统计单词出现的次数,spout将持续输入的一句句话作为输入流,bolt将一句话分割成单...