Morning Cat

白茶清欢无别事我在等风也等你

CompletableFuture API 笔记

1. 异步开启一个任务 supplyAsync Supplier : T get() 无入参，有返回值 runAsync Runnable : void run() 无返回值 2. 任务后置处理 thenApply Function<? su...

Posted by BY morningcat on August 30, 2021

Maven 依赖中的 scope 标签含义

可参考官网文档大致有 complie(缺省值),test,provided,runtime,system,import 等选项； complie 示例 <dependency> <groupId>com.mycompany.app</groupId> <artifactId>my-app<...

Posted by BY morningcat on December 21, 2020

深入理解 Kafka 读书笔记 8 -- 生产者重要参数

背景：kafka 生产者架构 github code 参数

Posted by BY morningcat on July 10, 2020

深入理解 Kafka 读书笔记 7 -- 生产者分区器

背景：kafka 生产者架构概念 org.apache.kafka.clients.producer.Partitioner org.apache.kafka.clients.producer.internals.DefaultPartitioner

Posted by BY morningcat on July 10, 2020

深入理解 Kafka 读书笔记 6 -- 生产者拦截器

背景：kafka 生产者架构概念拦截器是 Kafka 0.10.0.0 引入的功能分类生产者拦截器消费者拦截器功能可以用来在消息发送前做一些准备工作修改消息、完善消息过滤不需要发送的消息 ...

Posted by BY morningcat on July 10, 2020

深入理解 Kafka 读书笔记 5 -- 序列化器

背景：kafka 生产者架构概念生产者需要用序列化器把对象转换成字节数组才能通过网络发送给 Kafka 服务器消费者需要用反序列化器把从 Kafka 服务器中收到的字节数组转换成相应的对象序列化器与反序列化器需要一一对应序列化器需要实现 org.apache.kafka.common.serialization.Serializer 接口反序列化器需要实...

Posted by BY morningcat on July 10, 2020

深入理解 Kafka 读书笔记 4 -- 生产者架构

kafka 生产者架构消息在由 KafkaProducer 发往 Kafka 服务器（Broker or Kafka Cluster）之前，需要经历可能的拦截器、序列化器、分区器等一系列的作用；生产者客户端由两个线程协调运行主线程由 KafkaProducer 创建消息，然后通过可能的拦截器、序列化器和分区器的作用之后缓存到消息累加器（ Re...

Posted by BY morningcat on July 10, 2020

深入理解 Kafka 读书笔记 3 -- java 基础 API

基础 API <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.5.0</version> </dependency> ...

Posted by BY morningcat on July 10, 2020

深入理解 Kafka 读书笔记 2 -- 基本概念

kafka 的功能消息系统 Kafka 与传统的消息系统（消息中间件）都具备系统解耦、冗余存储、流量削峰、缓冲、异步通信、扩展性、可恢复性等功能；存储系统 Kafka 把消息持久化到磁盘，可以把 Kafka 作为长期的数据存储系统来使用，只需要把对应的数据保留策略设置为永久或启用主题的日志压缩功能；流式处理平台为多个流行的流式处理框架提供了可靠的数...

Posted by BY morningcat on July 10, 2020

深入理解 Kafka 读书笔记 1 -- 环境搭建与脚本测试

安装 JDK … Zookeeper 环境前提： JDK 已安装成功 Zookeeper 环境搭建笔记 Kafka 环境前提： JDK 已安装成功 Zookeeper 已启动下载解压 tar zxvf kafka_2.12-2.5.0.tgz 配置 vi conf/server.properties # 主要配置项 brok...

Posted by BY morningcat on July 10, 2020