使用明确的数据类型，避免使用模糊的数据类型，例如ESObject。

Oracle实时数据抽取项目问题总结项目背景介绍项目主要是将Oracle、MySQL、SQLServer、Db2等其他数据库的实时变更数据同步到其他异构数据库中。本篇文章主要是讨论oracle的实时采集，通过Logminer捕获归档日志，然后将提取后的数据推送到Kafka中。项目使用的技术框架使用的核心框架：https://github.com/debezium/debezium用于捕获归档日志，

简介介绍计算框架对java开发的重要性介绍flink的架构介绍flink的基本概念：常用算子、checkpoint、state、window介绍flink的编程模型：DataStream、DataSet、Table API、SQL介绍flink的部署计算框架每个Java开发一定要懂至少一个流行的计算框架，因为现在的数据量越来越大，光靠数据库或者手写代码去实现难度已经越来越大，不仅涉及到资源调度，还

简介介绍消息队列的重要性介绍Java程序员常用的Kafka消息队列介绍Kafka内部的一些机制及注意问题为什么要使用消息队列？比较常见的作用有3点，解耦、异步处理、流量削峰，这里分别一一介绍这些特点。解耦我们在设计微服务的时候经常会出现几个模块之间需要相互依赖，例如A和B服务相互依赖，那么部署一个A，必须部署一个B，导致A模块和B模块之间形成了强耦合。如果此时我们在A和B模块之间引入消息队列，那么