Spring Boot与Kafka集成(六)

(1). 概述这一小节,主要把Kafka与SpringBoot进行集成,并能发送和接受消息.(2). 项目结构lixin-macbook:kafka-example lixin$ tree .├── pom.xml├── src│   ├── m...

Spring Boot与Kafka集成源码之KafkaProperties(七)

(1). 概述前面把SpringBoot与Kafka进行了集成,配置都是从官网去拉下来的,但是,为了能够深入到底有哪些配置项是可以配的,需要找到,Kafka的业务模型.

Spring Boot与Kafka集成源码之@KafkaListener(八)

(1). 概述由于SpringBoot对Kafka进行了包装,只是留出了一个注解给我们了,在这一小篇,主要剖析:@KafkaListener注解,以及了解该注解能支持哪些参数签名.

Spring Boot与Kafka集成源码之ConcurrentMessageListenerContainer(九)

(1). 概述前面剖析到MessageListenerContainer接口,这个接口主要负责转化业务模型,并真正与Kafka进行通信,实现订阅功能,它有两个实现类,分别是:ConcurrentMessageListenerContainer和K...

Kafka生产者配置和案例(四)

(1). 概述在这一小节,主要学习下Kafka生产者的使用与配置.

Kafka消费者案例(五)

(1). 概述在这一小节,主要学习Kakfa对消息的消费,并注意几个配置参数(offset提交/拉取的最大批次).

Kafka常用命令(三)

(1). 概述前面自己搭了一个Kafka集群,在这里对Kafka的常用命令进行一个学习

Kafka集群安装(二)

(1). 概述在这一篇主要是对Kakfa进行集群的安装.

免费SSL证书申请实践

(1). 概述以前申请证书,都是由运维去处理,最近有一些运维的工作要处理,所以,就想自己尝试下申请免费SSL证书,并记录下来. “参考地址”(2). 操作步骤 CentOS 服务器一台(略) 域名配置IP解析(略) 安装Nginx并配置se...

Debezium本地运行(三)

(1). 概述前面通过Docker运行了Debezium,但是,通过Docker之后,你会感觉到Debezium是一个黑盒了,所以,从这一篇开始,通过源码编译Debezium,并,在本机跑Debezium的Demo.

Doker运行Hive

(1). 前言自己搭建一台Hive,需要很长的时间(依赖Hadoop),现在Docker的流行,在网上找了一个,发现,Hive有对Docker的支持,所以,只是为了测试,就偷个懒.

数仓分层模型介绍

(1). 前言

Kafka单机安装(一)

(1). 概述最近在研究Debezium,由于它和Kafka有强耦合,所以,需要研究下Kafka.

在Docker运行Debezium(二)

(1). 概述前面对debezium进行了一个大概的了解,在这一里,通过docker来运行一个简单的案例.

Axon入门

(1). CQRS概述为什么要选择CQRS模式来实现微服务? 在传统的应用结构中,应用通常要对在数据库中持久化的数据进行操作.通常为数据模型实体使用唯一的数据库,同时用于读取和写入.数据的设计由写入和更新操作驱...

谈单元测试的重要性

(1). 引言看一些优秀的框架,会发现都有一个共同点,那就是它们基本上每一个类都伴随着一个相应的:测试类. 在这里,主要讨论什么是单元测试,为什么需要单元测试.结合自己的一些看法,应该要如何去实践单元测试...

Spring源码之SpringRunner(一)

(1). 概述

Junit源码之JUnitCore(一)

(1). 概述

Liquibase源码之UpdateVisitor(三)

(1). 概述在前面,剖析了Liquibase会对XML进行解析,解析后数据保存在:DatabaseChangeLog对象里,DatabaseChangeLog承载着所有的业务模型数据. 那么,Liquibase是何时对DatabaseCha...

Liquibase源码之CustomChange(四)

(1). 概述在前面,剖析了Liquibase解析XML,并执行SQL,那么,我们能否扩展Change呢?Liquibase提供了扩展类:CustomChange和XML标签.

Liquibase源码之ChangeLogParserFactory(一)

(1). 概述从前面的学习,大概的了解到,Liquibase会读取XML,并转换成SQL文件,最终会在目标库运行脚本(保证一致性/元子性). 那么,Liquibase是如何解析XML的呢?能否支持扩展呢?答案就在:ChangeLogParserF...

Liquibase源码之ChangeLogParser(二)

(1). 概述 前面对Liquibase进行了简单的集成,心里有一个疑问,Liquibase是如何把ChangLog(XML/JSON/YAML/SQLFile)进行解析,并执行的? 原理就在ChangeLogParser

Binder详解

(1). 背景Spring是如何把Environment转换成GatewayProperties对象的?

Debezium简介

(1). Debezium是什么?Debezium是由RedHat(这是一家典型靠文档盈利的公司)开源的一个项目,该项目是为了:捕获数据更改(change data capture,CDC)提供了一个低延迟的流式处理平台. ...

Debezium源码编译(一)

(1). 编译要求 Git 2.2.1 or later JDK 11 or later, e.g. OpenJDK Apache Maven 3.6.3 or later Docker Engine or Docker Desktop ...

独立租户部署Sass系统,成本节约解决方案(二)

(1). 背景随着微服务的流行,业务模块越来越多后,对机器的要求也越来越高,一个小项目(20个微服务),按最小内存计算(512M),部署起来,都要10G左右的内存. 在前面的篇幅,有类似的解决方案,但是,要把所有的依赖放在指定目录下,并配置...

SpringBoot DevTools 源码学习

(1). 添加依赖<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools&...

X-Pipe 介绍(一)

(1). X-Pipe 是什么X-Pipe是由携程框架部门研发的Redis多数据中心复制管理系统.基于Redis的Master-Slave复制协议,实现低延时、高可用的Redis多数据中心、跨公网数据复制,并且提供一键机房切换,复制监控、异常报警...

ToGAF基础知识

(1). 什么是无边界信息流无边界信息流:即通过安全、可靠和及时的全球互操作性达成企业内部及外部的信息集成与有效访问,并最终实现企业业务流程管理的集成.无边界并不是没有边界,而是相对的无边界.我们所强调的无边界是让企业业务部门在权限内快速、有效、...

ThingsBoard 简介

(1). ThingsBoard是什么ThingsBoard是一个开源平台,用于收集和可视化物联网设备的数据.可以将来自任意数量设备的数据发送到云服务器,在云服务器中可以通过可自定义的仪表板查看或共享.