JDBC连接数据库创建一个以JDBC连接数据库的程序，包含7个步骤：1、加载JDBC驱动程序：在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机），这通过java.lang.Class类的静态方法forName(StringclassName)实现。例如：try{...

咱们上文讲到 Linux就是一个文件形式的操作系统而且当我们第一次打开的时候就会进入root用户工作目录阶段,然后对于Linux而言绿色文件相当于是文件夹黑色文件是文件 而有些重点标注的文件是具有全部权限的我们只需要找到Linux里存放server的位置找到catlina,out就是实时的查看服务器具体的位置我们一般需要命令行有:ll 展现当前工作目录的文件与文件夹cd切换...

一.什么是kettleKettle是一款国外开源的ETL工具，纯java编写，可以在Window、Linux、Unix上运行，绿色无需安装，数据抽取高效稳定。中文名称叫水壶，该项目的主程序员MATT 希望把各种数据放到一个壶里，然后以一种指定的格式流出。二.kettle的四种产品　Chef（中文：厨师）、Kitchen（中文：厨房）、Spoon（中文：勺子）、Pan（中文：平底锅）...

一.主题（Topic）主题（Topic）：发布订阅的对象，我们可以为每个业务，每个应用甚至是每类数据都创建专属的主题。生产者（Producer）：向主题发布消息的客户端应用程序，生产者程序通常持续不断的向一个或多个主题发送消息。消费者（Consumer）订阅这些主题消息的客户都安应用程序；消费者也能同时订阅多个主题消息。我们把生产者和消费者统称为客户端（clients）同时运行多个生产者和消费者实

Consumer端位移和消息在分区中的位移不是一回事是下一条消息的位移，而不是目前最新消费消息的位移例子：假设一个分区中有10条消息，位移分别是0到9其中consumer应用已消费了5条消息，就说明该consumer消费了位移为0到4的5条消息，此时Consumer位移是5，指向了下一条消息的位移。consumer需要向Kafka汇报自己的位移数据，这个汇报过程被称为提交位移（Committing

一.创建TCP连接消费者端主要的程序入口是KafkaConsumer类。生产者不同的是，构建KafkaConsumer实例时是不会创建任何TCP连接的也就是执行完new KafkaConsumer(porperties)语句后，你会发现没有socket连接被创建出来。与Java生产者的区别：生产者入口类KafkaProducer再构建实例的时候，会在后台默默启动一个Sender线程，这个Sende

一.kafka生产者程序概览kafka的Java生产者API主要对象就是kafkaProducer构造生产者对象所需参数对象创建kafka对象实例使用kafkaProducer的send方法发送消息调用kafkaProducer的close方法关闭生产者并释放各种系统资源。Properties props=new Properties();props.put(“参数1”, “参数1的值”)；pro

一.为什么分区kafka主题（Topic）：是承载真是数据的逻辑容器主题之下由若干分区，kafka的消息组织方式是三级结构：主题-分区-消息；主题下的每条消息只会保存在某一个分区中，不会再多个分区中被保存多份。kafka为甚使用分区的概念而不是直接使用多个主题分区的作用是提供负载均衡的能力,实现数据的高伸缩性（Scalability）不同分区能够被放置在不太节点的机器上，而数据读写操作也是针对分区

消费者Lag或Consumer Lag：监控他们的消费进度了，或者监控他们消费的滞后程度滞后程度：指消费者当前落后于生产者的程度比如说：Kafka生产者向某主题成功生产了100万消息，你的消费者当前消费了80w条消息，那么你的消费者滞后了20万条消息，即Lag等于20w。Lag单位消息数：我们是在主题级别上讨论Lag，实际上Kafka监控Lag的层级是在分区上。手动汇总所有主题分区的Lag，累加起

一.请求/响应所有的请求都是通过 TCP 网络以 Socket 的方式进行通讯的。Apache Kafka自定义的请求协议：PRODUCE请求是用于生产消息的FETCH请求是用于消费消息的METADATA请求适用于请求Kafka集群元数据信息的。所有的请求都是通过TCP网络以Socket的方式通讯的。二.Reactor模式Reactor模式：事件驱动架构的实现方式，适合应用于处理多个客户端并发向服